这个问题类似于将kafka用作（cqrs）事件存储。好主意？但更具体的实现。当我有数千个事件“源”（ddd中的聚合根）时，如何使用kafka作为事件存储？正如我在链接问题和其他一些地方读到的，我会对每个来源的主题有问题。如果我按类型将事件拆分为主题，那么使用和存储会容易得多，但我需要访问特定源的事件流。如何与Kafka进行活动采购？
smdnsysy1#
将所有事件源发布到一个具有数据类型（thrift？）的主题，该数据类型包括每个事件源的一些唯一标识符。然后为您感兴趣的每个事件类型创建消费者，并用唯一的消费者组名称标识每个事件类型。这样，每个唯一的源使用者将在zookeeper中拥有自己的偏移值。每个人都阅读整个主题，但只输出（或处理）单一来源（或一组来源）的信息。
1条答案
按热度按时间smdnsysy1#
将所有事件源发布到一个具有数据类型（thrift？）的主题，该数据类型包括每个事件源的一些唯一标识符。然后为您感兴趣的每个事件类型创建消费者，并用唯一的消费者组名称标识每个事件类型。这样，每个唯一的源使用者将在zookeeper中拥有自己的偏移值。每个人都阅读整个主题，但只输出（或处理）单一来源（或一组来源）的信息。