V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
牛客网
sq1036
V2EX  ›  问与答

kafka 虚拟机内 shell 可以正常生产消费 远程连接创建消费者消费就没反应 有遇到过同样问题的吗?网上找了半天也没找到解决办法 能 ping 通 且防火墙都已关闭

  •  
  •   sq1036 · 2019-03-29 10:12:44 +08:00 · 542 次点击
    这是一个创建于 575 天前的主题,其中的信息可能已经有所发展或是发生改变。
    代码如下

    package com.yn.kafkatoredis.demo;

    import org.apache.kafka.clients.consumer.ConsumerRecord;
    import org.apache.kafka.clients.consumer.ConsumerRecords;
    import org.apache.kafka.clients.consumer.KafkaConsumer;

    import java.util.Arrays;
    import java.util.Properties;


    public class MyKafkaConsumer {
    public static void main(String[] args) {

    Properties props = new Properties();
    props.put("bootstrap.servers", "192.168.100.100:9092");
    props.put("group.id", "wtf");//消费者的组 id
    props.put("enable.auto.commit", "true");
    props.put("auto.commit.interval.ms", "1000");
    props.put("session.timeout.ms", "30000");
    props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
    props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

    KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);
    //订阅主题列表 topic
    consumer.subscribe(Arrays.asList("test"));

    while (true) {
    ConsumerRecords<String, String> records = consumer.poll(100);
    for (ConsumerRecord<String, String> record : records)
    System.out.printf("offset = %d, key = %s, value = %s", record.offset(), record.key(), record.value()+"\n");
    }
    }
    }
    sq1036
        1
    sq1036   2019-03-29 10:13:29 +08:00
    控制台什么也没有 把 IP 端口 改成错的也不报错
    ksedz
        2
    ksedz   2019-03-29 10:20:27 +08:00
    我记得 kafka 会走 hostname ?你配置下 /etc/hosts 试试
    sq1036
        3
    sq1036   2019-03-29 10:24:11 +08:00
    @ksedz 已配置 试了 还是不行 好奇怪啊 莫名其妙
    关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   1025 人在线   最高记录 5168   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 22ms · UTC 20:46 · PVG 04:46 · LAX 13:46 · JFK 16:46
    ♥ Do have faith in what you're doing.