You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by va...@apache.org on 2019/12/10 10:06:46 UTC
[camel-kafka-connector] branch master updated (d2762b7 -> 8a69950)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from d2762b7 Merge pull request #28 from apache/transform
add 869a66c Decouple kafka test service from the local container
add 8a69950 Support using an external Kafka for the tests (#29)
No new revisions were added by this update.
Summary of changes:
README.adoc | 6 +++
.../camel/kafkaconnector/AbstractKafkaTest.java | 29 ++++++++---
.../apache/camel/kafkaconnector/ContainerUtil.java | 8 +--
.../apache/camel/kafkaconnector/TestCommon.java | 9 ++--
.../services/kafka/ContainerLocalKafkaService.java | 33 ++++++-------
.../services/kafka/KafkaService.java | 57 ++++++++++++++++++++++
.../services/kafka/KafkaServiceFactory.java | 43 ++++++++++++++++
.../services/kafka/RemoteKafkaService.java | 22 +++++----
.../sink/aws/sns/CamelSinkAWSSNSITCase.java | 19 +++-----
.../sink/aws/sqs/CamelSinkAWSSQSITCase.java | 23 +++------
.../sink/file/CamelSinkFileITCase.java | 22 +++------
.../sink/http/CamelSinkHTTPITCase.java | 24 +++------
.../sink/jms/CamelSinkJMSITCase.java | 20 +++-----
.../aws/kinesis/CamelSourceAWSKinesisITCase.java | 18 +++----
.../source/aws/s3/CamelSourceAWSS3ITCase.java | 18 +++----
.../source/aws/sqs/CamelSourceAWSSQSITCase.java | 22 +++------
.../source/jms/CamelSourceJMSITCase.java | 19 +++-----
.../source/timer/CamelSourceTimerITCase.java | 24 +++------
18 files changed, 229 insertions(+), 187 deletions(-)
copy core/src/main/java/org/apache/camel/kafkaconnector/VersionUtil.java => tests/src/test/java/org/apache/camel/kafkaconnector/AbstractKafkaTest.java (57%)
copy core/src/test/java/org/apache/camel/kafkaconnector/test/TestBlockingQueueFactory.java => tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/ContainerLocalKafkaService.java (52%)
create mode 100644 tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/KafkaService.java
create mode 100644 tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/KafkaServiceFactory.java
copy core/src/main/java/org/apache/camel/kafkaconnector/VersionUtil.java => tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/RemoteKafkaService.java (61%)