This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 340b13d CAMEL-12503: Fixed test as breadcrumbId header is included by
default.
340b13d is described below
commit 340b13d888b3f139b19681916757b166d191cdaa
Author: Claus Ibsen <[email protected]>
AuthorDate: Tue May 15 13:50:10 2018 +0200
CAMEL-12503: Fixed test as breadcrumbId header is included by default.
---
.../java/org/apache/camel/component/kafka/KafkaProducerFullTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java
index 643c783..4e9a69e 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerFullTest.java
@@ -336,7 +336,8 @@ public class KafkaProducerFullTest extends
BaseEmbeddedKafkaTest {
ConsumerRecord<String, String> record = records.get(0);
Headers headers = record.headers();
assertNotNull("Kafka Headers should not be null.", headers);
- assertEquals("One propagated header is expected.", 5,
headers.toArray().length);
+ // we have 5 headers and 1 header with breadcrumbId
+ assertEquals("One propagated header is expected.", 6,
headers.toArray().length);
assertEquals("Propagated string value received",
propagatedStringHeaderValue,
new String(getHeaderValue(propagatedStringHeaderKey,
headers)));
assertEquals("Propagated integer value received",
propagatedIntegerHeaderValue,
--
To stop receiving notification emails like this one, please contact
[email protected].
