Streamsql&&Kafka demo

    
     一、建Kafka数据源

    
     1. 登陆您集群中的一台安装了Kafka的节点(node4,192.168.100.54)(zookeeper 192.168.100.51-53)。进入/usr/lib/kafka/bin目录，该目录下有建Kafka数据源的

    
     所需要的一些脚本。

    
     1. 建一个Kafka Topic

    
     执行下面指令，运行/usr/lib/kafka/bin目录下的kafka-create-topic.sh脚本：

    ./kafka-create-topic.sh –partition 3 –topic demo –zookeeper 192.168.100.51:2181 –broker 192.168.100.54:9092
   

    2.

     查看Kafka Topic 执行下面指令，运行/usr/lib/kafka/bin目录下的kafka-list-topic.sh脚本

    ./kafka-list-topic.sh –zookeeper 192.168.100.51:2181
   

    
     3. 建Kafka producer并发布消息

    
     执行下面指令，运行/usr/lib/kafka/bin目录下的kafka-console-producer.sh脚本：