Package org.apache.kafka.streams.processor.internals

Class StreamsProducer

java.lang.Object

org.apache.kafka.streams.processor.internals.StreamsProducer

Direct Known Subclasses:

TestDriverProducer

public class StreamsProducer
extends 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.

Constructor Summary

Constructors

Constructor	Description
StreamsProducer(StreamsConfig config, String threadId, KafkaClientSupplier clientSupplier, TaskId taskId, UUID processId, org.apache.kafka.common.utils.LogContext logContext)

Method Summary

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,
                       String threadId,
                       KafkaClientSupplier clientSupplier,
                       TaskId taskId,
                       UUID processId,
                       org.apache.kafka.common.utils.LogContext logContext)

Method Detail

resetProducer

public void resetProducer()