kafka消費者java版本讀取不到訊息怎麼辦

時間 2021-06-14 05:06:33

1樓:

遇到了同樣的問題

update:

開始一直懷疑是配置的問題,查了半天發現用錯了包= = !

有問題的包:

org.apache.kafka

kafka_2.9.2

0.8.2.2

這裡邊的poll函式是個空輪詢。

後來換成了:

org.apache.kafka

kafka-clients

0.9.0.1

一切都好了。

2樓:距離

Properties props = new Properties();

props.put("bootstrap.servers", "192.

168.200.7:

9092,192.168.200.

8:2181,192.168.

200.9:2181");

props.put("group.id", "test2");

props.put("key.deserializer", "org.

apache.kafka.common.

serialization.StringDeserializer");

props.put("value.deserializer", "org.

apache.kafka.common.

serialization.StringDeserializer");

KafkaConsumer consumer=new KafkaConsumer(props);

consumer.subscribe(Arrays.asList("keduox"));

while(true){

ConsumerRecords records=consumer.poll(1000);

for (ConsumerRecord record : recordsSystem.out.

printf("offset = %d, key = %s, value = %s\n", record.offset(), record.key(), record.

value

怎麼看待三星的gear vr消費者版本?

之前從沒體驗過VR,剛好手頭有一部s8 索性又買了gear vr5代。使用體驗 相當爽。尤其是玩遊戲時,真的會有身臨其境的感受。缺點是畫質太渣,視野也不夠寬闊。據說gear vr已經是手機vr中的NO.1,所以真不敢想象其它裝置用起來會怎樣。在廢寢忘食地玩兒了三天後,到了第四天,我本能地就不想再碰它...

配眼鏡時不會直接給消費者鏡片,消費者怎麼知道最後配好的眼鏡上的鏡片是購買的高檔鏡片鏡片?

千尋585 有點可以留防偽標誌,不過加工後不一定能留住。為什麼鏡片防偽標誌加工後不一定能留住 這是凱公尺U6磨1.6和1.67折射率的鏡片防偽。不過有點鏡片就是能留下防偽,但防偽標誌卻很難看見的 有點坑 像精工,尼康。廣告 精工愛普視鏡片庫存處理 一,付款前提前要求店家留下鏡片包裝。這時老鼠屎心裡就...

為什麼營銷一定要以消費者為中心,以消費者客觀存在的需求為導向

金Lison 首先,這句話是乙個定義。然後請看現實 甲方營銷者在做的事 產品 售賣 消費者乙方營銷公司 產品 售賣 消費者 非剛需 消費者 產品的廣告 支付渠道 使用體驗 剛需 消費者 需求 產品對比 產生產品口碑看你站在以上哪個位置,營銷要綜合考慮。為中心,為導向 這個結論有點形而上,但基本是上述...