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-kafka-connector.git.
from b4143a1 Merge pull request #123 from orpiske/remove-unused-class
new 1052f40 Fix rest server initialization preventing the bogus NPE
during test startup
new c6cf977 Move the creation of the runner service to a separate class
new b952b76 Adds code to use Kafka's own embeddable connect cluster and
adjust the code to use it
new d0d77b0 Prevent multiple log4j bindings
new 59f93df Silent Kafka's Connect rest server invalid initialization
warnings
new fe7c364 Merge pull request #124 from
orpiske/use-kafka-embedded-connect
The 300 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
parent/pom.xml | 51 ++++++++-
tests/pom.xml | 91 ++++++++++++++--
.../camel/kafkaconnector/AbstractKafkaTest.java | 4 +-
.../camel/kafkaconnector/PluginPathHelper.java | 118 +++++++++++++++++++++
.../services/kafka/EmbeddedKafkaService.java | 87 +++++++++++++++
.../services/kafka/KafkaServiceFactory.java | 15 ++-
.../DefaultKafkaConnectPropertyFactory.java | 5 +-
.../kafkaconnect/KafkaConnectEmbedded.java | 87 +++++++++++++++
.../services/kafkaconnect/KafkaConnectRunner.java | 1 +
.../KafkaConnectRunnerFactory.java} | 33 +++---
.../source/jms/CamelJMSPropertyFactory.java | 1 -
tests/src/test/resources/log4j2.properties | 16 ++-
12 files changed, 470 insertions(+), 39 deletions(-)
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/PluginPathHelper.java
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/services/kafka/EmbeddedKafkaService.java
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/services/kafkaconnect/KafkaConnectEmbedded.java
copy
tests/src/test/java/org/apache/camel/kafkaconnector/services/{kafka/KafkaServiceFactory.java
=> kafkaconnect/KafkaConnectRunnerFactory.java} (53%)
