 |
|
Super8
现在不努力,将来怎么带你装逼。
V2EX 第 317492 号会员,加入于 2018-05-20 19:15:20 +08:00今日活跃度排名 4237
|
现在不努力,将来怎么带儿子装逼。不过我不介意你带我玩。
 |
根据 Super8 的设置,主题列表被隐藏 |
二手交易 相关的信息,包括已关闭的交易,不会被隐藏
Super8 最近回复了
可以在消息的 key 或者 value 中添加标识,例如在消息的 key 中添加 B 、C 、D 等标识,表示该消息是发给 B 、C 、D 的,然后在消费者端使用带有过滤条件的消费者来消费消息,只消费自己需要的消息。具体可以使用 Kafka 的 Consumer API 提供的 subscribe 方法中的参数来实现,例如使用 subscribe(Collections.singleton(topic), new MyPartitionAssignor()) 方法,其中 MyPartitionAssignor 实现了 PartitionAssignor 接口,可以根据标识来分配分区。另外,也可以使用 Kafka Streams 来实现消息过滤和分发。