夏老師C++socket網(wǎng)絡(luò)編程大全實(shí)戰(zhàn)http服務(wù)器支持php
2023-08-19 16:29 作者:每天3個(gè)拼課小技巧__ | 我要投稿
?//消費(fèi)者組
? ? ? ?properties.put(ConsumerConfig.GROUP_ID_CONFIG, "youngyoungyoung");
? ? ? ?//創(chuàng)建消費(fèi)者
? ? ? ?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());
? ? ? ? ? ?}
? ? ? ?}
標(biāo)簽：
