You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/10/24 07:57:00 UTC
[jira] [Commented] (ARTEMIS-1478) ActiveMQ Artemis to Kafka Bridge
[ https://issues.apache.org/jira/browse/ARTEMIS-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216484#comment-16216484 ]
ASF GitHub Bot commented on ARTEMIS-1478:
-----------------------------------------
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 <mi...@me.com>
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
----
> ActiveMQ Artemis to Kafka Bridge
> --------------------------------
>
> Key: ARTEMIS-1478
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1478
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Reporter: Michael Andre Pearce
>
> To create a service connector to bridge messages in similar fashion as a core bridge to kafka.
> The first scope of this is to provide an Artemis to Kafka bridge, but the end goal (another jira later) to provide the return leg.
> This essentially would mean for a data flow clients can connect and produce to a data flow on all the supported protocols (amqp, core, mqtt etc) and like wise consume, but also on the same data flow you can have kafka consumers.
> http://activemq.2283324.n4.nabble.com/Kafka-ServiceConnector-td4731430.html#a4731436
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)