This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git
from ee8b9447706 CAMEL-20281 - Camel-AWS Components: Make it possible to
use AwsSessionCredentials to support temporary credentials - AWS S3 (#12819)
add 8232b52fa89 CAMEL-16064: preliminary refactoring of camel-kafka
(#12820)
No new revisions were added by this update.
Summary of changes:
.../camel/component/kafka/KafkaFetchRecords.java | 3 +-
.../AbstractKafkaRecordProcessorFacade.java | 90 ++++++++++++
.../consumer/support/KafkaRecordProcessor.java | 159 +--------------------
.../support/KafkaRecordProcessorFacade.java | 142 ++----------------
.../kafka/consumer/support/ProcessingResult.java | 11 +-
.../classic/OffsetPartitionAssignmentAdapter.java | 11 +-
.../KafkaRecordStreamingProcessor.java} | 73 +++++-----
.../KafkaRecordStreamingProcessorFacade.java} | 108 ++++++--------
.../kafka/KafkaIdempotentRepository.java | 4 +-
9 files changed, 208 insertions(+), 393 deletions(-)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/AbstractKafkaRecordProcessorFacade.java
copy
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{KafkaRecordProcessor.java
=> streaming/KafkaRecordStreamingProcessor.java} (71%)
copy
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{KafkaRecordProcessorFacade.java
=> streaming/KafkaRecordStreamingProcessorFacade.java} (59%)
