kafka客户端jar java

wlsrxk51 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(836)

我正在尝试学习kafka.zookeper服务器和kafka，并安装在一个ubuntuaws node.zookeper服务器上，与三个代理和一个消费者一起运行。我在maven项目（在我的笔记本电脑上）中使用java客户机（kafka-clients0.9.0.1）将数据发送给aws上的代理和消费者。
有必要让zookeeper和kafka在我的本地系统上运行以连接到aws上的kafka吗？我的本地系统上有Windows10。
连接到kafka群集时，代理显示以下>信息由于请求无效而关闭到/xx.xx.xx.xx的套接字连接：长度为1195725856的请求无效，它大于最大大小104857600字节(Kafka.网络.处理器）

apache-kafka amazon-web-services kafka-consumer-api

来源：https://stackoverflow.com/questions/37482252/kafka-clients-jar-java