我使用 apachestorm 作为分发系统来消耗和产生高负载的 Kafka 消息。到目前为止,我只发送了彻底 apache Storm 的消息,但现在我正试图通过 Storm 添加 Kafka 标头和消息正文。我想知道apache风暴是否支持这个?
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-kafka</artifactId>
<version>1.2.2</version>
</dependency>
<dependency>