This is an automated email from the ASF dual-hosted git repository. orpiske pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git.
from cbdc15d Upgrade to activemq 5.17.0 add 1409138 CAMEL-17849: fix invalid log message during kafka consumer shutdown add 8aa2219 CAMEL-17850: fix trying to unlock an invalid lock add c0d0f38 camel-kafka: fix idempotent tests add d964ded (chores) camel-kafka: cleanup Kafka consumer initialization tasks No new revisions were added by this update. Summary of changes: .../camel/component/kafka/KafkaConsumer.java | 6 +- .../camel/component/kafka/KafkaFetchRecords.java | 101 ++++++++++++--------- .../kafka/KafkaIdempotentRepositoryEagerIT.java | 8 +- .../kafka/KafkaIdempotentRepositoryNonEagerIT.java | 12 +-- .../KafkaIdempotentRepositoryPersistenceIT.java | 10 +- 5 files changed, 80 insertions(+), 57 deletions(-)