apache-kafka - 在 nifi 集群优化上使用KafkaRecord

Question

我在具有 3 个动物园管理员的 nifi 中使用 3 节点集群。一般流程是 <read from kafka> -> <process data> -> <upload to DB> kafka 消费是否应该只在主节点上运行，以防止每隔几秒钟进行一次组重新平衡？

标签： apache-kafkaapache-nifiapache-zookeeper

Answer 1

不，kafka 消耗处理器在集群中运行良好。juste make sur 为您的连接器定义相同的 group.id。

如果您有再平衡问题，您应该首先查看您的 kafka 集群和 nifi 稳定性。