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

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

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

    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  
    OP
       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  
    OP
       2019-03-29 10:24:11 +08:00
    @ksedz 已配置 试了 还是不行 好奇怪啊 莫名其妙
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   2922 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 28ms · UTC 14:07 · PVG 22:07 · LAX 07:07 · JFK 10:07
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.