Add warning for fromJavaConsumer

zio · Jul 23, 2024 · 5e5ca7c · 5e5ca7c
1 parent 8dc16f3
commit 5e5ca7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala
@@ -197,7 +197,7 @@ object Consumer {
   /**
    * Create a zio-kafka Consumer from an org.apache.kafka KafkaConsumer
    *
-   * You are responsible for creating and closing the KafkaConsumer
+   * You are responsible for creating and closing the KafkaConsumer. Make sure auto.commit is disabled.
    */
   def fromJavaConsumer(
     javaConsumer: JConsumer[Array[Byte], Array[Byte]],