class StreamsProducer {

    public void resetProducer() {
        if (processingMode != EXACTLY_ONCE_BETA) {
            throw new IllegalStateException(formatException("Exactly-once beta is not enabled"));
        }

        producer.close();

        producer = clientSupplier.getProducer(eosBetaProducerConfigs);
        transactionInitialized = false;
    }

    public  StreamsProducer(final StreamsConfig config,
                           final String threadId,
                           final KafkaClientSupplier clientSupplier,
                           final TaskId taskId,
                           final UUID processId,
                           final LogContext logContext);

}