class StreamsProducer {

    boolean eosEnabled() {
        return processingMode == StreamThread.ProcessingMode.EXACTLY_ONCE_ALPHA ||
            processingMode == StreamThread.ProcessingMode.EXACTLY_ONCE_BETA;
    }

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

}