利用Java客户端简单操作kafka（读写操作）_java kafka读写数据到本地

作者：我家自动化 | 2024-08-15 21:12:06

踩

java kafka读写数据到本地

这里先简单地利用Java客户端向Kafka发送简单的消息，String类型的字符串。

首先，需要导入相关的包。我们选择Maven工程。相关的依赖如下：


<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka -->
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.11</artifactId>
    <version>0.9.0.0</version>
</dependency>

修改Kafka的配置文件：在kafka/config/server.properties中，修改hostname为ip地址（原来为localhost：）

（查看IP地址：ifconfig -a）

（如果不修改，就会造成：在安装有Kafka的机器上可以正常读写消息，但是，在其他的机器上就nos，也不会报错误！）

接下来：

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/985222