Kafka Streams - Revision history

Donsez at 10:48, 20 June 2017

2017-06-20T10:48:58Z

← Older revision		Revision as of 10:48, 20 June 2017
Line 1:		Line 1:
			http://kafka.apache.org/documentation/streams

	http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/		http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/

2016-09-16T16:02:25Z

← Older revision		Revision as of 16:02, 16 September 2016
Line 2:		Line 2:

	http://docs.confluent.io/3.0.0/streams/		http://docs.confluent.io/3.0.0/streams/

			=Getting started=

			<pre>
			wget http://packages.confluent.io/archive/3.0/confluent-3.0.0-2.11.zip
			unzip confluent-3.0.0-2.11.zip

			# * IMPORTANT STEP **
			# The subsequent paths and commands used throughout this quickstart assume that
			# your are in the following working directory:
			<pre>
			cd confluent-3.0.0/
			</pre>

			<pre>
			# Start ZooKeeper. Run this command in its own terminal.
			cd confluent-3.0.0/
			./bin/zookeeper-server-start ./etc/kafka/zookeeper.properties
			</pre>

			Next we launch the Kafka broker, which will listen on localhost:9092 and connect to the ZooKeeper instance we just started. Since this is a long-running service, too, you should run it in its own terminal.
			<pre>
			# Start Kafka. Run this command in its own terminal
			cd confluent-3.0.0/
			./bin/kafka-server-start ./etc/kafka/server.properties
			</pre>



			First, we need to create the input topic, named streams-file-input:

			<pre>
			./bin/kafka-topics --create \
			--zookeeper localhost:2181 \
			--replication-factor 1 \
			--partitions 1 \
			--topic streams-file-input
			</pre>

			Next, we generate some input data and store it in a local file at /tmp/file-input.txt:


			<pre>
			echo -e "all streams lead to kafka\nhello kafka streams\njoin kafka summit" > /tmp/file-input.txt
			</pre>

2016-09-13T12:25:21Z

Created page with "http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/ http://docs.confluent.io/3.0.0/streams/"

New page

http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/

http://docs.confluent.io/3.0.0/streams/