public class SimpleConsumer implements Callable<Integer>
{
private final String id;
- private final String topic;
+ private final String[] topics;
private final Consumer<String, String> consumer;
private long consumed = 0;
{
try
{
- log.info("{} - Subscribing to topic {}", id, topic);
- consumer.subscribe(Arrays.asList(topic));
+ log.info("{} - Subscribing to topics: {}", id, topics);
+ consumer.subscribe(Arrays.asList(topics));
while (true)
{