GitHub user michaelandrepearce opened a pull request:
https://github.com/apache/activemq-artemis/pull/1607
Artemis Kakfa Integration Bridge
ARTEMIS-1478 - ActiveMQ Artemis to Kafka Bridge
Initial Kafka Bridge for Apache ActiveMQ Artemis to Apache Kafka, using
Serivce Connector interface
Support to handle Core or AMQP based protocol over kafka.
Ensured for Core TextMessage can map to StringSerializer for a consumer
Ensure for Core ByteMessage can map to ByteArraySerializer for a consumer
Kafka Serdes to support kafka consumers to consumer Core or AMQP back to
CoreMessage, ProtonMessage, or JMSMessage
Added Documentation
Add integration tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/michaelandrepearce/activemq-artemis
ARTEMIS-1478
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/activemq-artemis/pull/1607.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1607
----
commit 77937f23864425d544a7842e13e71b4cd39c0608
Author: Michael André Pearce <[email protected]>
Date: 2017-10-24T07:51:36Z
Artemis Kakfa Integration Bridge
ARTEMIS-1478 - ActiveMQ Artemis to Kafka Bridge
Initial Kafka Bridge for Apache ActiveMQ Artemis to Apache Kafka, using
Serivce Connector interface
Support to handle Core or AMQP based protocol over kafka.
Ensured for Core TextMessage can map to StringSerializer for a consumer
Ensure for Core ByteMessage can map to ByteArraySerializer for a consumer
Kafka Serdes to support kafka consumers to consumer Core or AMQP back to
CoreMessage, ProtonMessage, or JMSMessage
Added Documentation
Add integration tests
----
---
