oscerd commented on issue #1347: URL: https://github.com/apache/camel-kafka-connector/issues/1347#issuecomment-1075986066
This is because you're using the 1.0.x version based on Kamelet. There is no keyName option there. echo "hello there" | ./kafkacat -b localhost:9092 -H "CamelHeader.customerName=customer" -H "CamelHeader.interval=01-02" -t mytopic This command is how you should send your kafka record to your topic before the sink connector start consuming messages from it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
