Kafka引入了共享消费者组的新功能,允许多个消费者共享一个分区并能够以任意顺序消费消息。这个新功能提供了作业队列的好处,如无限队列深度和可重放性,同时仍然使用Kafka作为队列而不改变底层基础设施。共享组协调器管理消费者组并跟踪每个记录的处理状态。消费者可以确认、释放或拒绝消息,还可以处理有毒记录。这个新功能提供了消费者以任意顺序消费消息的可用性。
完成下面两步后,将自动完成登录并继续当前操作。