kafka-connect-rabbitmq
kafka-connect-rabbitmq copied to clipboard
jonahharris
Fork of the RabbitMQ Source/Sink for Kafka Connect
How can I build this plugin? Just running maven install fails: `Failure to find com.palantir.docker.compose:docker-compose-rule-core:pom:0.34.0`
The program currently only supports MQ Basic consume, and does not support consume based on routing key. Currently the routing strategy of the queue need to be defined in advance....
Add option to add a formatter when writing data to RabbitMQ: - Added the sink connector option "rabbitmq.format" - Before you had to use the ByteArrayConverter to use the RabbitMQ...
Hello, I'm really new to Kafka Connect and RabbitMQ, so sorry for any mistakes I may write. I can't make this connector work with a RabbitMQ queue with DLX. It...
Hello, I am learning about the official website of'kafka-connect-activemq sink'. There is no information and documentation about sink, but I need information similar to'kafka-connect-rabbitmq sink'. I hope you can help...
Bumps [com.rabbitmq:amqp-client](https://github.com/rabbitmq/rabbitmq-java-client) from 5.10.0 to 5.18.0. Release notes Sourced from com.rabbitmq:amqp-client's releases. v5.18.0 Changes between 5.17.0 and 5.18.0 This is a minor release with usability improvements and dependency upgrades. It...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps org.apache.avro:avro from 1.8.2 to 1.11.3. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Metadata
Owner
Metadata
Fork of the RabbitMQ Source/Sink for Kafka Connect