{
private final ExecutorService executor;
private final String id;
private final String topic;
private final Consumer<K, V> consumer;
{
private final ExecutorService executor;
private final String id;
private final String topic;
private final Consumer<K, V> consumer;