夏老师C++socket网络编程大全实战http服务器支持php
2023-08-19 16:29 作者:每天3个拼课小技巧__ | 我要投稿
//消费者组
properties.put(ConsumerConfig.GROUP_ID_CONFIG, "youngyoungyoung");
//创建消费者
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(properties);
//订阅主题
consumer.subscribe(Collections.singletonList("first"));
while (true) {
ConsumerRecords<String, String> consumerRecords = consumer.poll(100);
//解析并遍历ConsumerRecords
for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {
System.out.println(consumerRecord.key() + "---" + consumerRecord.value());
}
}
