我有一个数据负载,它对于一条消息来说太大了。考虑一个avro: record Likes {...}
record Comments {...}
record Post {
Likes likes;
Comments comments;
string body;
} 假设点赞和评论是很大的集合,如果将它们和帖子一起传递,它将超过最大消息大小,我认为增加到10-20MB是不正确的。 我想把一条消息分成三条:帖子正文,评论和点赞。但是,我希望数据库插入是原子性,因此我希望在消费者内存中对这些消息进行分组和合并。 我能用kafka-streams做吗?我可以有一个没有输出主题的流吗(因