java - Kafka消费者偏移量自动重置等参数

Question

我有一个 KafkaConsumer 需要订阅两个主题topicA和topicB. 但是我需要一些参数不同。例如，如果我需要一段auto.offset.reset时间，它应该是。我认为没有简单的方法可以做到这一点。一种选择是运行两个消费者，但在这种情况下，我需要两个轮询线程，因此应该处理多线程。有没有更简单的方法？topicAearilesttopicBlatest

标签： javaapache-kafkakafka-consumer-api

Answer 1

创建两个（或更多）线程是正确的。

消费者不是线程安全的，无论如何都应该与其他进程隔离和分离。

您可以使用更高级别的 Kafka 库（例如 Vert.x / Spring）来简化此操作。