这家伙太懒,什么都没留下
好的 ,谢谢您 我测试一下
我测试过了,消息没丢。步骤:1、先把要发送的消息写到test.txt中。2、执行发送 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test < test.txt 消费者正常拿到全部消息。
编辑好了
上面那个字符串中 msgbody中b集合里我实际发送的大概有50个对象。但是由于评论有字数限制,里边的对象数量较少。
我测试是正常的。