[GitHub] camel pull request: CAMEL-9108: Fix KafkaProducer URI

Github user williamd1618 closed the pull request at: https://github.com/apache/camel/pull/597 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] camel pull request: Fix KafkaProducer URI

GitHub user williamd1618 reopened a pull request: https://github.com/apache/camel/pull/597 Fix KafkaProducer URI Guarantees that if the KafkaEndpoint has a UriParam of topic the KeyedMessage will be sent to that topic, if it does not have a topic and the Exchange message

[GitHub] camel pull request: Fix KafkaProducer URI

Github user williamd1618 closed the pull request at: https://github.com/apache/camel/pull/597 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] camel pull request: Feature/kafka deferred offset commit

GitHub user williamd1618 opened a pull request: https://github.com/apache/camel/pull/602 Feature/kafka deferred offset commit Currently the Camel Kafka connect auto-commits or commits in batch based upon the countdown of a CyclicBarrier from the varying partitions as they await

[GitHub] camel pull request: Fix KafkaProducer URI

GitHub user williamd1618 opened a pull request: https://github.com/apache/camel/pull/597 Fix KafkaProducer URI Guarantees that if the KafkaEndpoint has a UriParam of topic the KeyedMessage will be sent to that topic, if it does not have a topic and the Exchange message

[GitHub] camel pull request: Fix Endpoint URI for KafkProducer

Github user williamd1618 closed the pull request at: https://github.com/apache/camel/pull/596 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] camel pull request: Fix Endpoint URI for KafkProducer

GitHub user williamd1618 opened a pull request: https://github.com/apache/camel/pull/596 Fix Endpoint URI for KafkProducer When doing a route from Kafka topic to Kafka topic I noticed that functionality like: ``` from("kafka:localhost:9092?topic=from&zook

Camel RabbitMQConsumer and header preservation

Hi, I noticed that the 2.12.x development branch was not preserving the RabbitMQ Headers when consuming messages. I've created a ticket with a patch and added a ticket: https://issues.apache.org/jira/browse/CAMEL-6708 This patch was created off of commit aeaeb3e5dfdaf71c67929b4b4622f9b87e672b2e