class StreamsProducer {

    Map<MetricName, ? extends Metric> metrics() {
        return producer.metrics();
    }

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

}