tree 623eb2f71c627314c3bb7a22b125589b96d51dc6
parent 6693ea1ce1a2ed2e0e63943fb3a5f89769ba3cdb
author SiMing Weng <siming.weng@gmail.com> 1565284512 -0400
committer Ning Wang <nwang@twitter.com> 1565284512 -0700

Kafka bolt (#3324)

* update KafkaSpout

* Revert "update KafkaSpout"

This reverts commit dc64e9ad

* implement a Kafka Bolt

* add unit tests for Effective Once and At Most Once mode