You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@heron.apache.org by GitBox <gi...@apache.org> on 2019/02/25 22:28:21 UTC

[GitHub] simingweng opened a new pull request #3198: Feature/create kafka spout

simingweng opened a new pull request #3198: Feature/create kafka spout
URL: https://github.com/apache/incubator-heron/pull/3198
 
 
   This is a KafkaSpout implemented using Heron Spout API.
   
   It supports both AT_MOST_ONCE and AT_LEAST_ONCE message delivery guarantee, and there's a sample project showcasing how it is used in the simplest topology on a Simulator. The sample topology requires a local Kafka broker to run and test.
   
   The project is currently a Maven project rooted at `incubator-heron/contrib/spouts/kafka/java/heron-kafka-spout-parent`, and depends on publicly available maven dependency `heron-api`. When it is converted to a Bazel target, it should cross reference the in-tree Heron API target.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services