kafka消息在客户机中被拆分

r7knjye2  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(173)

我是Kafka的新人。我正在向rest服务器发送请求,并将请求的响应作为消息发送到kafka服务器。
当我使用来自消费者的数据时,消息被拆分为多个较小的消息。如何避免这种情况。响应是一个json行。我希望每个json行都是一条消息。任何帮助都将不胜感激。json的大小也不是很大。超过1500行的json大约是2MB
例如
消费者记录(topic='meetup\u sample',partition=0,offset=445386,>timestamp=1530554568191,timestamp\u type=0,>key=b'5fa4964b035c072a81fedb93cfca8f0ecb562cf913c69f63efbbf4e799871f05',>value=b':“食品和饮料”,“topic\u name”:“食品和饮料”},{“urlkey”:“newintown”,“topic\u name”:“newin town”},{“urlkey”:“啤酒”,“topic\u name”',>checksum=none,序列化的\u key \u size=64,序列化的\u value \u size=128)消费者记录(topic='meetup \u sample',partition=0,offset=445387,>timestamp=1530554568192,timestamp \u type=0,>key=b'1f170ceabf91335d33487ebb0890f0bd0ed69018c618ecc2c789a260d561f43',>value=b':“beer”},{“urlkey”:“game night”,“topic\u name”:“game night”},{“urlkey”:“happy hours”,“topic\u name”:“happy hour”},{“urlkey”:“water-s',>checksum=none,serialized\u key\u size=64,serialized\u value\u size=128)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题