Description
error javadoc:
consumer.subscribe("topic");
fix:
consumer.subscribe(Arrays.asList("topic"));
Since KafkaConsumer.subscribe() method uses List as the input type, using string "topic" will get an error.
error javadoc:
consumer.subscribe("topic");
fix:
consumer.subscribe(Arrays.asList("topic"));
Since KafkaConsumer.subscribe() method uses List as the input type, using string "topic" will get an error.