fix: default config

gojek · Aug 24, 2023 · 6032e56 · 6032e56
1 parent 170b9dc
commit 6032e56
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/ziggurat/config.clj b/src/ziggurat/config.clj
@@ -136,8 +136,6 @@
    :default-api-timeout-ms-config   :default-api-timeout-ms
    :key-deserializer-class-config   :key-deserializer
    :session-timeout-ms-config       :session-timeout-ms
-   :max-poll-interval-ms            :max-poll-interval-ms
-   :max-poll-records                :max-poll-recrords
    :value-deserializer-class-config :value-deserializer})
 
 (def producer-config-mapping-table

diff --git a/src/ziggurat/kafka_consumer/consumer.clj b/src/ziggurat/kafka_consumer/consumer.clj
@@ -8,6 +8,7 @@
 (def default-consumer-config
   {:commit-interval-ms              15000
    :session-timeout-ms-config       60000
+   :max-poll-interval-ms            300000
    :default-api-timeout-ms-config   60000
    :key-deserializer-class-config   "org.apache.kafka.common.serialization.ByteArrayDeserializer"
    :value-deserializer-class-config "org.apache.kafka.common.serialization.ByteArrayDeserializer"})
@@ -16,7 +17,8 @@
   [topic-entity consumer-group-config]
   (try
     (let [merged-consumer-group-config (umap/deep-merge consumer-group-config default-consumer-config)
-          consumer                     (KafkaConsumer. (cfg/build-consumer-config-properties merged-consumer-group-config))
+          consumer                     (KafkaConsumer.
+                                        (cfg/build-consumer-config-properties merged-consumer-group-config))
           topic-pattern                (Pattern/compile (:origin-topic merged-consumer-group-config))]
       (.subscribe consumer topic-pattern)
       consumer)