You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by gi...@apache.org on 2024/01/19 09:01:44 UTC

(camel) branch regen_bot updated (6a7e8b66779 -> 132217ba0f9)

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 6a7e8b66779 Bump elasticsearch-java-client-version from 8.11.4 to 8.12.0
     add 132217ba0f9 CAMEL-16064: added batching classes

No new revisions were added by this update.

Summary of changes:
 .../org/apache/camel/catalog/components/kafka.json | 396 +++++++++++----------
 .../component/kafka/KafkaComponentConfigurer.java  |   3 +
 .../component/kafka/KafkaEndpointConfigurer.java   |   3 +
 .../component/kafka/KafkaEndpointUriFactory.java   |   3 +-
 .../org/apache/camel/component/kafka/kafka.json    | 396 +++++++++++----------
 .../camel/component/kafka/KafkaConfiguration.java  |  14 +
 .../camel/component/kafka/KafkaFetchRecords.java   |  15 +-
 .../consumer/support/KafkaRecordProcessor.java     |  54 ++-
 .../batching/KafkaRecordBatchingProcessor.java     | 113 ++++++
 .../KafkaRecordBatchingProcessorFacade.java        |  62 ++++
 .../streaming/KafkaRecordStreamingProcessor.java   |  45 +--
 .../BatchingProcessingITSupport.java}              |  54 +--
 .../batching/KafkaBatchingProcessingIT.java        |  95 +++++
 13 files changed, 758 insertions(+), 495 deletions(-)
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessorFacade.java
 copy components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/{commit/BaseManualCommitTestSupport.java => batching/BatchingProcessingITSupport.java} (59%)
 create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/batching/KafkaBatchingProcessingIT.java