private final String topic;
private final Consumer<String, Message> consumer;
- private volatile boolean running = false;
private long consumed = 0;
try
{
log.info("{} - Subscribing to topic test", id);
- consumer.subscribe(Arrays.asList("test"));
+ consumer.subscribe(Arrays.asList(topic));
running = true;
while (true)