downgrade kafka clients (#1872)

allegro · Jun 20, 2024 · 5754069 · 5754069
1 parent a478894
commit 5754069
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -48,7 +48,7 @@ allprojects {
     targetCompatibility = JavaVersion.VERSION_17
 
     project.ext.versions = [
-            kafka             : '3.6.2',
+            kafka             : '2.8.2',
             guava             : '33.1.0-jre',
             jackson           : '2.17.0',
             jersey            : '3.1.6',

diff --git a/...tend/src/main/java/pl/allegro/tech/hermes/frontend/producer/kafka/KafkaMessageSender.java b/...tend/src/main/java/pl/allegro/tech/hermes/frontend/producer/kafka/KafkaMessageSender.java
@@ -96,7 +96,7 @@ public void send(ProducerRecord<K, V> producerRecord,
 
     private static RecordMetadata exceptionalRecordMetadata(CachedTopic cachedTopic) {
         var tp = new TopicPartition(cachedTopic.getKafkaTopics().getPrimary().name().asString(), RecordMetadata.UNKNOWN_PARTITION);
-        return new RecordMetadata(tp, -1, -1, RecordBatch.NO_TIMESTAMP, -1, -1);
+        return new RecordMetadata(tp, -1, -1, RecordBatch.NO_TIMESTAMP, -1L, -1, -1);
     }
 
     List<PartitionInfo> loadPartitionMetadataFor(String topic) {