Revert "rebase with upstream/main"

This reverts commit b009700.
strimzi · Mar 4, 2024 · 115c84d · 115c84d
1 parent 8824a2c
commit 115c84d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/io/strimzi/kafka/bridge/http/HttpSourceBridgeEndpoint.java b/src/main/java/io/strimzi/kafka/bridge/http/HttpSourceBridgeEndpoint.java
@@ -229,7 +229,7 @@ private MessageConverter<K, V, byte[], byte[]> buildMessageConverter(String cont
                 return (MessageConverter<K, V, byte[], byte[]>) new HttpJsonMessageConverter();
             case BridgeContentType.KAFKA_JSON_BINARY:
                 return (MessageConverter<K, V, byte[], byte[]>) new HttpBinaryMessageConverter();
-            case BridgeContentType.KAFKA_JSON_TEXT:
+            case TEXT:
                 return (MessageConverter<K, V, byte[], byte[]>) new HttpTextMessageConverter();
         }
         return null;

diff --git a/src/test/java/io/strimzi/kafka/bridge/http/ProducerIT.java b/src/test/java/io/strimzi/kafka/bridge/http/ProducerIT.java
@@ -268,7 +268,7 @@ void sendTextMessage(VertxTestContext context) throws InterruptedException, Exec
         consumerProperties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaUri);
 
         KafkaConsumer<String, String> consumer = KafkaConsumer.create(vertx, consumerProperties,
-                new StringDeserializer(), new StringDeserializer());
+                new StringDeserializer(), new KafkaJsonDeserializer<>(String.class));
         consumer.handler(record -> {
             context.verify(() -> {
                 assertThat(record.value(), is(value));