You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/01/14 12:34:00 UTC
[camel] branch master updated (5ac8406 -> 437320d)
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