[
https://issues.apache.org/jira/browse/SAMZA-262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495136#comment-17495136
]
Nicolò Scarpa commented on SAMZA-262:
-------------------------------------
I've created a library that provides both a basic SystemConsumer and a
SystemProducer for RabbitMQ, following the code of the official Kafka lib. The
lib is already published on OSSRH under the name "samza-rabbitmq" version
"0.0.1". This is the public repo for the lib:
https://github.com/nickshoe/samza-rabbitmq.
> Create SystemConsumer and SystemProducer for RabbitMQ
> -----------------------------------------------------
>
> Key: SAMZA-262
> URL: https://issues.apache.org/jira/browse/SAMZA-262
> Project: Samza
> Issue Type: Improvement
> Reporter: Jakob Homan
> Priority: Major
> Labels: gsoc2015, java
>
> [RabbitMQ|https://www.rabbitmq.com/] is a popular messaging queue. It would
> be good to be able to read to and write from it. Per the discussion [about
> leveldb|https://issues.apache.org/jira/browse/SAMZA-236?focusedCommentId=13985982&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13985982]
> this support should be separated into its own package and project (jar) for
> easy testing and severability.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
