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)
log.info("{}: Consumed {} messages in total, exiting!", id, consumed);
}
}
-
- public void start()
- {
- executor.submit(this);
- }
}