Apache Storm Maven 对 KafkaProducerTopology 对象的依赖

Question

导入的 Maven 依赖项是什么 org.apache.storm.kafka.bolt.KafkaProducerTopology 我用过 :

<dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-kafka</artifactId>
        <version>1.0.1</version>
        <scope>provided</scope>
</dependency>`

但它不起作用。我需要一个有效版本的 Kafka-Server xml，但我在任何地方都找不到。

Answer 1

这是来自示例的 class，不属于任何 Maven 依赖项

https://github.com/apache/storm/blob/master/examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/bolt/KafkaProducerTopology.java