change serializer and content type

Signed-off-by: Antonio Pedro <[email protected]>
strimzi · Mar 4, 2024 · 2dd3965 · 2dd3965
1 parent 115c84d
commit 2dd3965
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 TEXT:
+            case BridgeContentType.KAFKA_JSON_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 KafkaJsonDeserializer<>(String.class));
+                new StringDeserializer(), new StringDeserializer());
         consumer.handler(record -> {
             context.verify(() -> {
                 assertThat(record.value(), is(value));