我已经在云服务器上安装了kafka,希望从本地系统连接cloud-kafka服务器
我的云kafka服务器内部IP:
10.340.0.90我的云kafka服务器公网IP:
aa.xx.yy.zz我的本地系统IP:
172.168.1.100文件名:config/server.properties
取消注释并更改了以下行:
#advertised.listeners=PLAINTEXT://:9092
to
advertised.listeners=PLAINTEXT://10.340.0.90:9092重新启动了卡夫卡,动物园管理员
尽管如此,我还是无法从我的本地网络连接远程kafka服务器
发布于 2018-05-24 09:53:33
您是否可以修改config/server.properties:
listeners=INTERNAL://10.340.0.90:9092, EXTERNAL://aa.xx.yy.zz:9093
inter.broker.listener.name=INTERNAL
并在源代码中配置引导服务器:
Producer:
Map props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, aa.xx.yy.zz:9093);
Consumer:
Map props = new HashMap<>();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, aa.xx.yy.zz:9093);
https://stackoverflow.com/questions/50489548
复制相似问题