빅데이터 분석을 위한 준비 Kafka + Python 연결
Kafka + Python 연결 테스트 #1 Start zookeeper & kafka [root@zepp zookeeper-3.4.14]# vi conf/zoo.cfg [root@zepp zookeeper-3.4.14]# bin/zkServer.sh start ZooKeeper JMX enabled by default Using config: /home/min/zookeeper-3.4.14/bin/../conf/zoo.cfg Starting zookeeper … STARTED [root@zepp kafka_2.12-2.2.0]# bin/kafka-server-start.sh config/server.properties [2019-04-19 18:12:03,572] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2019-04-19 18:12:04,104] INFO starting (kafka.server.KafkaServer) [2019-04-19 18:12:04,105] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer) [2019-04-19 18:12:04,128] INFO [ZooKeeperClient] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient) #2 create topic [root@zepp kafka_2.12-2.2.0]# ./bin/kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic suic