Class StreamsProducer


  • public class StreamsProducer
    extends java.lang.Object
    StreamsProducer manages the producers within a Kafka Streams application.

    If EOS is enabled, it is responsible to init and begin transactions if necessary. It also tracks the transaction status, ie, if a transaction is in-fight.

    For non-EOS, the user should not call transaction related methods.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void resetProducer()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • StreamsProducer

        public StreamsProducer​(StreamsConfig config,
                               java.lang.String threadId,
                               KafkaClientSupplier clientSupplier,
                               TaskId taskId,
                               java.util.UUID processId,
                               org.apache.kafka.common.utils.LogContext logContext)
    • Method Detail

      • resetProducer

        public void resetProducer()