Fix RestKafkaSender for latest REST proxy

RADAR-base · Sep 20, 2023 · 3de88b5 · 3de88b5
1 parent b4426bf
commit 3de88b5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/radar-commons/src/main/java/org/radarbase/producer/rest/RestKafkaSender.kt b/radar-commons/src/main/java/org/radarbase/producer/rest/RestKafkaSender.kt
@@ -255,7 +255,7 @@ class RestKafkaSender(config: Config) : KafkaSender {
         private val logger = LoggerFactory.getLogger(RestKafkaSender::class.java)
         val DEFAULT_TIMEOUT: Duration = 20.seconds
         val KAFKA_REST_BINARY_ENCODING = ContentType("application", "vnd.radarbase.avro.v1+binary")
-        val KAFKA_REST_JSON_ENCODING = ContentType("application", "vnd.kafka+json")
+        val KAFKA_REST_JSON_ENCODING = ContentType("application", "vnd.kafka.avro.v2+json")
         const val GZIP_CONTENT_ENCODING = "gzip"
 
         fun restKafkaSender(builder: Config.() -> Unit): RestKafkaSender =