相当于 kafkaConsumer.partitionsFor 使用反应式 kafka（akka kafka 流）

Question

我正在使用 reactive-kafka（akka kafka 流）：

https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html

以下使用 reactive-kafka 的代码等效于什么？

import org.apache.kafka.clients.consumer.KafkaConsumer
...
val properties = new Properties()
properties.put("bootstrap.servers", "kafka:9092")

val kafkaConsumer = new KafkaConsumer[String, String](properties)
kafkaConsumer.partitionsFor("my-topic")

Answer 1

目前没有直接暴露在 Reactive Kafka 中API。

这可能是因为 Reactive Kafka 以一种反应方式专注于流事件 to/from 基于 Akka-Streams consumers/producers。

您仍然可以使用官方 Kafka 客户端让消费者从集群中获取元数据。这不需要额外的依赖，因为它是由 Reactive Kafka 带来的。