java - kafka 可以创建topic,但是producer程序无法写入数据

 披着狼皮的卷毛羊万_784 发布于 2022-10-28 06:30

我在本地写了一个producer客户端程序

public class SimpleProducer {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9093"); //一旦改成远端主机就push消息失败了
        props.put("acks", "all");
        props.put("retries", 0);
        props.put("batch.size", 16384);
        props.put("linger.ms", 1);
        props.put("buffer.memory", 33554432);
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        Producer producer = new KafkaProducer(props);
        for(int i = 0; i < 100; i++)
            producer.send(new ProducerRecord("my-topic", "message from client: ", Integer.toString(i)));
        producer.flush() ;
        producer.close() ;
    }
}

这段代码在本地的zk+kafka运行很稳定,但是一旦把props.put("bootstrap.servers", "localhost:9093");改完远端主机的ip:port,push消息就会失败。
但是就算push消息失败,我的topic创建也仍然成功,这是什么原因造成的呢? 运行过程中也没有报错。。

撰写答案
今天,你开发时遇到什么问题呢?
立即提问
热门标签
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有