1 回答

TA貢獻1851條經驗 獲得超3個贊
好了,經過一些測試,我在Camel Configuration中讀取了此參數
bridgeEndpoint Default:false Camel 2.16.0: If bridgeEndpoint is true, the producer will ignore the topic header setting of the message.
因此,我嘗試添加到我的終點
<!--DEFINE KAFKA'S TOPCIS AS ENDPOINT-->
<endpoint id="tagBlink" uri="kafka:10.0.0.165:9092">
<property key="topic" value="tagBlink"/>
<property key="topic" value="tagBlink"/>
<property key="brokers" value="10.0.0.165:9092"/>
<property key="bridgeEndpoint " value="true"/>
</endpoint>
<!--END OF KAFKA'S TOPICS's AS ENDPOINT-->
<endpoint id="testMike" uri="kafka:10.0.0.165:9092">
<property key="topic" value="testMike"/>
<property key="brokers" value="10.0.0.165:9092"/>
<property key="bridgeEndpoint " value="true"/>
</endpoint>
并且無限循環停止了。
添加回答
舉報