消息没有被消费
Messages are not getting consumed
我在 application.properties 文件中添加了以下配置 Spring Boot with Camel implementation 但消息没有被消耗。我是否缺少任何配置?使用 kafka 协议和 Camel 从 Azure 事件中心实现消费者的任何指示?
bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
路线如下所示:
from("kafka:{{topicName}}?brokers=NAMESPACENAME.servicebus.windows.net:9093" )
.log("Message received from Kafka : ${body}");
我找到了这个问题的解决方案。由于我使用的是 Spring 启动自动配置 (camel-kafka-starter),application.properties 文件中的条目必须修改如下:
camel.component.kafka.brokers=NAMESPACENAME.servicebus.windows.net:9093
camel.component.kafka.security-protocol=SASL_SSL
camel.component.kafka.sasl-mechanism=PLAIN
camel.component.kafka.sasl-jaas-config =org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
使用 Kafka 协议的 Azure 事件中心的消费者路由如下所示:
from("kafka:{{topicName}}")
.log("Message received from Kafka : ${body}");
希望此解决方案有助于使用 Kafka 协议在 Camel 中使用来自 Azure 事件中心的事件
我在 application.properties 文件中添加了以下配置 Spring Boot with Camel implementation 但消息没有被消耗。我是否缺少任何配置?使用 kafka 协议和 Camel 从 Azure 事件中心实现消费者的任何指示?
bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
路线如下所示:
from("kafka:{{topicName}}?brokers=NAMESPACENAME.servicebus.windows.net:9093" )
.log("Message received from Kafka : ${body}");
我找到了这个问题的解决方案。由于我使用的是 Spring 启动自动配置 (camel-kafka-starter),application.properties 文件中的条目必须修改如下:
camel.component.kafka.brokers=NAMESPACENAME.servicebus.windows.net:9093
camel.component.kafka.security-protocol=SASL_SSL
camel.component.kafka.sasl-mechanism=PLAIN
camel.component.kafka.sasl-jaas-config =org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
使用 Kafka 协议的 Azure 事件中心的消费者路由如下所示:
from("kafka:{{topicName}}")
.log("Message received from Kafka : ${body}");
希望此解决方案有助于使用 Kafka 协议在 Camel 中使用来自 Azure 事件中心的事件