This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a commit to branch fix-tests in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
commit ad31705034b0a9e2623190c7ba7557df95357d6b Author: Nicolas Filotto <[email protected]> AuthorDate: Mon Jun 19 09:09:34 2023 +0200 camel-kafka - Set the correct partition id --- .../apache/camel/component/kafka/integration/KafkaProducerFullIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java index 04a884de53e..b6479f1bbff 100644 --- a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java +++ b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java @@ -282,11 +282,11 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport { CountDownLatch messagesLatch = new CountDownLatch(messageInTopic + messageInOtherTopic); Map<String, Object> inTopicHeaders = new HashMap<>(); - inTopicHeaders.put(KafkaConstants.PARTITION_KEY, "1".getBytes()); + inTopicHeaders.put(KafkaConstants.PARTITION_KEY, "0".getBytes()); sendMessagesInRoute(messageInTopic, bytesTemplate, "IT test message".getBytes(), inTopicHeaders); Map<String, Object> otherTopicHeaders = new HashMap<>(); - otherTopicHeaders.put(KafkaConstants.PARTITION_KEY, "1".getBytes()); + otherTopicHeaders.put(KafkaConstants.PARTITION_KEY, "0".getBytes()); otherTopicHeaders.put(KafkaConstants.TOPIC, TOPIC_BYTES_IN_HEADER); sendMessagesInRoute(messageInOtherTopic, bytesTemplate, "IT test message in other topic".getBytes(), otherTopicHeaders);
