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: [email protected] With regards, Apache Git Services
