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 2017/12/14 10:10:39 UTC
[camel] branch master updated (0572728 -> d72bcb6)
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 0572728 [CAMEL-12082] Set the TCCL to the application classloader when executing local route commands
add ed9d4d6 CAMEL-12076: Specified topic is ignored when KafkaConfiguration is used
new d72bcb6 CAMEL-12076: Fixed BaseEmbeddedKafkaTest
The 1 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:
.../apache/camel/component/kafka/KafkaComponent.java | 10 +++-------
.../apache/camel/component/kafka/KafkaEndpoint.java | 1 +
.../apache/camel/component/kafka/KafkaProducer.java | 19 ++++++++++++-------
.../camel/component/kafka/BaseEmbeddedKafkaTest.java | 2 +-
.../camel/component/kafka/KafkaProducerTest.java | 20 +++++++++++++++++---
5 files changed, 34 insertions(+), 18 deletions(-)
--
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].
[camel] 01/01: CAMEL-12076: Fixed BaseEmbeddedKafkaTest
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d72bcb65c0721bbb360072caf1303e4b58236fe0
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Dec 14 11:10:08 2017 +0100
CAMEL-12076: Fixed BaseEmbeddedKafkaTest
---
.../java/org/apache/camel/component/kafka/BaseEmbeddedKafkaTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/BaseEmbeddedKafkaTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/BaseEmbeddedKafkaTest.java
index c7b4f45..b3fc0cf 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/BaseEmbeddedKafkaTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/BaseEmbeddedKafkaTest.java
@@ -80,7 +80,7 @@ public class BaseEmbeddedKafkaTest extends CamelTestSupport {
CamelContext context = super.createCamelContext();
context.addComponent("properties", new PropertiesComponent("ref:prop"));
- KafkaComponent kafka = new KafkaComponent();
+ KafkaComponent kafka = new KafkaComponent(context);
kafka.setBrokers("localhost:" + getKafkaPort());
context.addComponent("kafka", kafka);
--
To stop receiving notification emails like this one, please contact
"commits@camel.apache.org" <co...@camel.apache.org>.