/trident-kafka

Kafka integration for Trident

Primary LanguageJavaApache License 2.0Apache-2.0

trident-kafka provides Trident spouts for Apache Kafka 0.7.

  1. Add blacklisting of Kafka servers in OpaqueTridentKafkaSpout
  2. Discover Kafka brokers dynamically through Zookeeper instead of using a static list of brokers
  3. Discover number of partitions / topic / host dynamically