|
|
1
1
Apache Kafka 基于推拉机制。生产者推送某个主题的数据,消费者则从该主题中提取数据。我们可以为消费者定义轮询间隔。 它不是基于观测器设计模式。然而,rest服务可用于数据摄取和数据消费,这被称为 kafka rest proxy . 就像当用户数据更改时,我们使用生产者Rest服务[Kafka Rest代理]将这些更改写在像UserTopic这样的主题上。我们已经在topic UserTopic上注册了五个消费者,他们将使用消费者Rest服务[卡夫卡Rest代理]来消费数据。 |