w

0 声望

这家伙太懒,什么都没留下

个人动态

奥巴马说我长得丑 kafka使用官网的java代码 生产者正常使用,消费者接收不到消息 发表评论:
consumer拉取消息的地方是不是没有死循环?
8月前
w 回复 半兽人 kafka使用官网的java代码 生产者正常使用,消费者接收不到消息 中 :
还是不行 。算了不搞了 搞了3-4天了 搞storm kafka整合和spark去了
1年前
半兽人 回复 w kafka使用官网的java代码 生产者正常使用,消费者接收不到消息 中 :
Properties props = new Properties(); props.setProperty("bootstrap.servers", "localhost:9092"); props.setProperty("group.id", "test"); props.setProperty("enable.auto.commit", "true"); props.setProperty("auto.commit.interval.ms", "1000"); props.setProperty("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); props.setProperty("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); KafkaConsumer consumer = new KafkaConsumer<>(props); consumer.subscribe(Arrays.asList("foo", "bar")); while (true) { ConsumerRecords records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord record : records) System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value()); }
1年前
w 回复 半兽人 kafka使用官网的java代码 生产者正常使用,消费者接收不到消息 中 :
没有。。。也没报错 感觉是这里问题 你们都是kafkaConsumer.poll(100)我这边就会显示过时 得用Duration的静态方法
1年前
w 回复 鲍记忠 kafka使用官网的java代码 生产者正常使用,消费者接收不到消息 中 :
可以 客户端的producer console-producer都可以用 就客户端的consumer接收不到数据
1年前

(゚∀゚ )
暂时没有任何数据