Skip to content

Instantly share code, notes, and snippets.

@harageth

harageth/gist:2256cbf6e9252dc2b1b89367dda35f56

Created January 26, 2017 23:22
Show Gist options
  • Save harageth/2256cbf6e9252dc2b1b89367dda35f56 to your computer and use it in GitHub Desktop.
Save harageth/2256cbf6e9252dc2b1b89367dda35f56 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
/opt/zookeeper/bin$ ./zkServer.sh start ../config/zookeeper.properties
/opt/kafka$ bin/kafka-server-start.sh config/server.properties
/opt/kafka$ $ bin/kafktopics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic flume-ingestor-test
/opt/kafka$ $ bin/kafktopics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic flume-aep-test
/opt/kafka$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic flu-aep-test
//I used this to verify that I created the topics correctly
/opt/kafka$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic flume-aep-test --from-beginning --zookeeper localhost:2181
sudo ./bin/flume-ng agent --conf /opt/ele/tests/conf/flume/ -f /opt/ele/tests/conf/flume/flume-conf-ingestor.properties -n ingestor
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment