java 发送消息的时候指定partKey。(如果不指定,则只能到1个分区中)
消费者同一个group下,消费同一个topic,最多partitions个线程可以收到消息(消息不同,可以配置分区策略),其他线程则无法收到消息。
消费者不同group下,可以消费同一个topic下消息,得到的内容是一样的。
-
Notifications
You must be signed in to change notification settings - Fork 1
kongzhidea/kafka
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published