Apache Kafka和Storm在非常短的時間內對大數據進行精確的實時流分析方麵互為補充。Kafka-Storm集成允許開發人員使用Storm拓撲輕鬆發布數據流並持續運行。

監督Kafka-Storm API集成的三個主要類是-

• BrokerHosts

BrokerHosts接口由兩個實現組成——ZkHosts和StaticHosts。ZkHosts提供了一種快速的方式來跟蹤和維護Kafka代理9n ZooKeeper的詳細信息，而StaticHosts手動選擇Kafka代理。

ZkHosts的簽名是-

public ZkHosts(String brokerZkStr, String brokerZkPath)

公共ZkHosts(字符串brokerZkStr)

其中brokerZkStr指的是ZooKeeper主機，brokerZkPath是維護Kafka代理及其詳細信息的ZooKeeper路徑。

• KafkaConfig API

這個API定義了Kafka集群的配置設置，它的簽名是-

KafkaConfig(BrokerHosts，字符串主題)

其中主機是BrokerHosts (ZkHosts / StaticHosts)，主題對應於主題的名稱。

• SpoutConfig API

這個API是KafkaConfigAPI的擴展，負責存儲額外的ZooKeeper信息。它的簽名是-

public SpoutConfig(BrokerHosts hosts, string topic, string zkRoot, string id)

其中zkRoot是ZooKeeper根路徑，id對應於標識噴口的偏移量的狀態。