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

Class TestDriverProducer

java.lang.Object

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

org.apache.kafka.streams.processor.internals.TestDriverProducer

public class TestDriverProducer
extends StreamsProducer

Constructor Summary

Constructors

Constructor	Description
TestDriverProducer(StreamsConfig config, KafkaClientSupplier clientSupplier, org.apache.kafka.common.utils.LogContext logContext)

Method Summary

Modifier and Type	Method	Description
void	commitTransaction(Map<TopicPartition,OffsetAndMetadata> offsets, ConsumerGroupMetadata consumerGroupMetadata)

Methods inherited from class org.apache.kafka.streams.processor.internals.StreamsProducer

resetProducer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestDriverProducer

public TestDriverProducer(StreamsConfig config,
                          KafkaClientSupplier clientSupplier,
                          org.apache.kafka.common.utils.LogContext logContext)

Method Detail

commitTransaction

public void commitTransaction(Map<TopicPartition,OffsetAndMetadata> offsets,
                              ConsumerGroupMetadata consumerGroupMetadata)
                       throws ProducerFencedException

Throws:

ProducerFencedException