Update Storm集成Kakfa.md
This commit is contained in:
parent
c12a356640
commit
790be02ed3
@ -170,7 +170,7 @@ public class WritingToKafkaApp {
|
|||||||
|
|
||||||
#### 1. 启动Kakfa
|
#### 1. 启动Kakfa
|
||||||
|
|
||||||
Kafka的运行依赖于zookeeper,需要预先启动,可以启动Kafka内置的zookeeper,也可以启动自己安装的。
|
Kafka的运行依赖于zookeeper,需要预先启动,可以启动Kafka内置的zookeeper,也可以启动自己安装的:
|
||||||
|
|
||||||
```shell
|
```shell
|
||||||
# zookeeper启动命令
|
# zookeeper启动命令
|
||||||
@ -364,4 +364,4 @@ public class DefaultRecordTranslator<K, V> implements RecordTranslator<K, V> {
|
|||||||
|
|
||||||
## 参考资料
|
## 参考资料
|
||||||
|
|
||||||
1. [Storm Kafka Integration (0.10.x+)](http://storm.apache.org/releases/2.0.0-SNAPSHOT/storm-kafka-client.html)
|
1. [Storm Kafka Integration (0.10.x+)](http://storm.apache.org/releases/2.0.0-SNAPSHOT/storm-kafka-client.html)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user