Apache-Kafka 中 AsyncKafkaConsumer 和 ClassicKafkaConsumer 的主要区别是什么

Question

Kafka API 为 Kafka 消费者提供功能，允许应用程序读取和处理来自 Kafka 主题的消息，并用于需要消费消息的应用程序。这是我们都知道的consumer-api 的通用方法。但是

AsyncKafkaConsumer

和

ClassicKafkaConsumer

之间的主要区别是什么？这些主要由 Kafka 内部使用，而不是通过 API 直接公开吗？

Answer 1

AsyncKafkaConsumer 和 ClassicKafkaConsumer 不是 Kafka 核心 API 的一部分。经典消费者使用阻塞 poll() 同步获取消息，使您可以完全控制处理和偏移提交。异步消费者通常使用回调或反应流非阻塞地获取和处理消息。虽然经典消费者是标准 Kafka API 的一部分，但异步模式通常由 Kafka 之上的框架或库实现