施磊C++全套數(shù)據(jù)結(jié)構(gòu)算法進(jìn)階
import java.util.Properties;public class MyConsumer {
? ?public static void main(String[] args) {
? ? ? ?//1.創(chuàng)建消費者配置信息
? ? ? ?Properties properties = new Properties();
? ? ? ?//2.給配置信息賦值
? ? ? ?//連接的集群
? ? ? ?properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.235.3:9092");
? ? ? ?//開啟自動提交
? ? ? ?properties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);
? ? ? ?//自動提交的延時
? ? ? ?properties.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");
? ? ? ?//key和value的反序列化
? ? ? ?properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
? ? ? ?properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
