У меня есть две конфигурации в моем файле свойств весенней загрузки, и я использую верблюда 2.23:
#camel.component.kafka.allow-manual-commit=true <-- works when i uncomment and use
###Why isnt the below option being picked up??
camel.component.kafka.configuration.allow-manual-commit=true <-- not working
Кажется, когда я использую camel.component.kafka.allow-manual-commit=true вместо пространства имен расширения .configuration .... все работает. но когда я использую конфигурацию один, он терпит неудачу .... т.е. он не обнаруживает allowManualCommit как true
Я посмотрел код для этого camel-kafka-starter в строке 31 и заметил, что он аннотирован, чтобы указывать на пространство имен camel.component.kafka. это имеет смысл, но откуда берется пространство имен .configuration ... Является ли значение по умолчанию 'false' для camel.component.kafka.allow-manual-commit, переопределяя истинное значение, которое я установил в camel.component.kafka.configuration. allow-manual-commit?
В моем коде у меня есть верблюжий маршрут с
from("kafka?{topic}")
, и где я использую объект KafkaManualCommit для commitSyn c ()