为什么Kafka0.10控制台制作人不能向Kafka0.9发送消息？
为什么Kafka0.10控制台制作人不能向Kafka0.9发送消息？
为什么新的生产者不能向老的消费者发送信息呢？有没有可能设置一个新的制作人在一种不推荐的模式，以发送消息给老Kafka？
$bin\windows\kafka-console-producer.bat--broker-list my_server:9092-topic my_topic
[2016-08-30 14:03:53,365]错误在kafka producer I/O线程中未捕获错误：（org.apache.kafka.clients.producer.internals.sender）org.apache.kafka.common.protocol.types.schemaException：读取字段“brokers”时出错：读取字段“host”时出错：读取长度为25452的字符串时出错，在org.apache.kafka.clients.networkclient.parseresponse（networkclient.networkclient.handlecompletedreceives（
共有1个答案
Kafka0.10.0引入了一种新的消息格式。我不是完全确定，但看起来你是在向一个显然对此一无所知的经纪人发送一个新格式的消息。
您应该尝试强制0.10生成器使用旧的消息格式。您可以在这里找到更多信息:http://kafka.apache.org/documentation.html#upgrade_10_breaking
-
我无法向Kafka主题发布消息，无法得到Kafka制作人的任何回应，它完全卡住了应用程序 Kafka生产者服务代码 2021-05-30 13:29:13.209[0；39M[32M信息[0；39M[35M2472[0；39M[2M---[0；39M[2M[nio-8084-exec-2][0；39M[36MO.apache.coyote.http11.HTTP11Processor[0；39M[
-
我在向我的Kafka主题发送序列化XML时遇到问题。每当我运行我的代码时，我都不会收到任何异常或错误消息，但我仍然无法在Kafka主题中看到我的任何消息。 我的Kafka制作人设置如下： 当我运行代码时，我得到： 知道怎么做吗？提前谢谢！
-
我在Cloudera中安装了一个3代理kerberised Kafka 0.10，我正在尝试通过SASL/PLAIN进行身份验证 我路过Kafka·贾斯。配置到每个代理上的JVM中。
-
我可以成功地从家里的服务器向Firebase服务器发送帖子请求。消息被毫无问题地传递到客户端。除了应用程序必须运行或在后台。如果应用程序被关闭，消息就会被搁置。系统托盘里什么都没有，没有声音，什么都没有。这是预期的行为吗？ 这是我正在使用的curl命令： curl-X POST--header“Authorization:key=AIzaSyBntseBqux9nBX8y”--header“Con
-
问题内容： 我有下一个Java类： 当我在Eclipse IDE中运行此代码时-在Eclipse控制台中看不到任何输出。 但是，如果我更改值 1448 并设置为 1447 以下，我会在控制台中看到输出（12345678 …） 因此，也许Eclipse IDE在控制台中对字符串长度有限制？ 你怎么看待这件事？ 谢谢。 问题答案： 在控制台中右键单击-> ->检查。现在，您具有自动自动换行功能，一切正
-
我试图通过控制台发送< code > SMS ，但显然我没有收到任何消息。 到目前为止我做了什么？ 创造了一个话题 创建了我的号码和电子邮件ID的订阅。 发表了一条消息 在我的电子邮件ID上，我可以接收相同主题的消息，但不能在手机上接收。 甚至尝试了其他手机，只是为了确保我的号码没有阻止消息，但结果是一样的，sns短信是不能通过控制台工作！！！