private final String topic;
private final Consumer<K, V> consumer;
private final ConsumerRebalanceListener rebalanceListener;
private final String topic;
private final Consumer<K, V> consumer;
private final ConsumerRebalanceListener rebalanceListener;