[camel] branch master updated (5ac8406 -> 437320d)

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[camel] branch master updated (5ac8406 -> 437320d)

acosentino
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.


    from 5ac8406  CAMEL-14354: camel-core - Optimize
     add 7ccb8e0  CAMEL-14308 - Upgrade to Kafka 2.4.x
     add 437320d  Camel-Kafka - Fixed CS

No new revisions were added by this update.

Summary of changes:
 .../component/kafka/DefaultKafkaManualCommit.java  |   4 +-
 .../kafka/DefaultKafkaManualCommitFactory.java     |   4 +-
 .../camel/component/kafka/KafkaComponent.java      |  51 ++++---
 .../camel/component/kafka/KafkaConfiguration.java  |  29 ++--
 .../camel/component/kafka/KafkaConstants.java      |   4 +-
 .../camel/component/kafka/KafkaEndpoint.java       |  24 +--
 .../component/kafka/KafkaHeaderFilterStrategy.java |   2 +-
 .../component/kafka/KafkaManualCommitFactory.java  |   7 +-
 .../camel/component/kafka/KafkaProducer.java       |  69 ++++-----
 .../kafka/serde/DefaultKafkaHeaderSerializer.java  |  13 +-
 .../kafka/KafkaIdempotentRepository.java           | 164 +++++++++++++--------
 .../component/kafka/BaseEmbeddedKafkaTest.java     |   9 +-
 .../camel/component/kafka/KafkaComponentTest.java  |  16 +-
 .../kafka/KafkaConsumerBatchSizeTest.java          |  14 +-
 .../component/kafka/KafkaConsumerFullTest.java     |  24 ++-
 .../kafka/KafkaConsumerLastRecordHeaderTest.java   |   6 +-
 .../kafka/KafkaConsumerManualCommitTest.java       |  18 +--
 .../KafkaConsumerOffsetRepositoryEmptyTest.java    | 101 -------------
 .../KafkaConsumerOffsetRepositoryResumeTest.java   | 102 -------------
 .../KafkaConsumerRebalancePartitionRevokeTest.java | 117 ---------------
 .../kafka/KafkaConsumerRebalanceTest.java          |  15 +-
 .../kafka/KafkaConsumerTopicIsPatternTest.java     |  11 +-
 .../component/kafka/KafkaProducerFullTest.java     |  70 ++++-----
 .../camel/component/kafka/KafkaProducerTest.java   |  21 ++-
 .../component/kafka/MockConsumerInterceptor.java   |   2 +-
 .../component/kafka/MockProducerInterceptor.java   |   2 +-
 .../kafka/embedded/EmbeddedKafkaBroker.java        |  26 +---
 .../kafka/embedded/EmbeddedZookeeper.java          |   1 -
 .../serde/DefaultKafkaHeaderDeserializerTest.java  |   4 +-
 .../serde/DefaultKafkaHeaderSerializerTest.java    |  18 +--
 .../kafka/KafkaIdempotentRepositoryEagerTest.java  |  17 ++-
 .../KafkaIdempotentRepositoryNonEagerTest.java     |  21 ++-
 .../src/test/resources/log4j2.properties           |   4 +-
 parent/pom.xml                                     |   4 +-
 34 files changed, 339 insertions(+), 655 deletions(-)
 delete mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerOffsetRepositoryEmptyTest.java
 delete mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerOffsetRepositoryResumeTest.java
 delete mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerRebalancePartitionRevokeTest.java