|
@@ -9,8 +9,6 @@ import java.util.Properties;
|
|
|
|
|
|
|
|
|
|
|
|
|
public class KafkaUtils {
|
|
public class KafkaUtils {
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
public static KafkaConsumer<String, String> createConsumer(List<String> topic) {
|
|
public static KafkaConsumer<String, String> createConsumer(List<String> topic) {
|
|
|
Properties properties = new Properties();
|
|
Properties properties = new Properties();
|
|
|
properties.put("bootstrap.servers", Config.KAFKA_SERVERS);
|
|
properties.put("bootstrap.servers", Config.KAFKA_SERVERS);
|