我使用的是React性Kafka（akka-kafka-streams）：
https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html
下面的代码使用React式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")
1条答案
按热度按时间vsdwdz231#
这是目前没有直接暴露在ReactKafkaapi。
这可能是因为React式Kafka专注于以一种React式的方式向/从基于akka流的消费者/生产者传递流事件。
您仍然可以使用正式的kafka客户机让使用者从集群获取元数据。这不需要额外的依赖关系，因为它是由被动Kafka带来的。