190.5.2. 将消息生成到 Kafka

以下是将信息写入 Kafka 所需的最小路由。

from("direct:start")
    .setBody(constant("Message from Camel"))          // Message to send
    .setHeader(KafkaConstants.KEY, constant("Camel")) // Key of the message
    .to("kafka:test?brokers=localhost:9092");