Windows下kafkaインストールとquikstart
1基礎環境win 10,jdk 1.8 2 kafka_2.11-0.10.1.1 kafkaをダウンロードし、指定ディレクトリに解凍する、例えばC:/kafka 3変更起動ファイル3.1 binwindows下のbatファイルをbinフォルダ下に移動し、不要なものを削除する.shファイル3.2 zookeeper-server-startを変更する.bat、 kafka-server-start.bat、kafka-run-class.batファイル
3.3 kafka-run-classを修正する.batスクリプトを起動します.javaがC:/Program Files/パスの下にある場合(または他のパスにスペースがある場合)
3.4起動プロファイルのログパスに対する構成serverを変更する.properties
zookeeper.properties
4起動kafka
5簡単な使用
win 10の下で作成して、ソフトリンクの方式を使って経路の問題を避けますhttp://gnarvind.blogspot.kr/2016/12/kafka-windows-10.htmlwin 7で作成して使用http://lehoon.com/backend/2016/08/22/kafka-window.html公式サイトhttp://kafka.apache.org/
%~dp0../../# %~dp0../
#
....
SetLocal
IF ["%KAFKA_LOG4J_OPTS%"] EQU [""] (
set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%~dp0../config/log4j.properties
)
IF ["%KAFKA_HEAP_OPTS%"] EQU [""] (
....
3.3 kafka-run-classを修正する.batスクリプトを起動します.javaがC:/Program Files/パスの下にある場合(または他のパスにスペースがある場合)
...
set JAVA="%JAVA_HOME%/bin/java"
...
set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %* #%CLASSPATH% ""
...
3.4起動プロファイルのログパスに対する構成serverを変更する.properties
...
log.dirs=d:/resp/kafka/tmp/kafka-logs
...
zookeeper.properties
dataDir=d:/resp/kafka/tmp/zookeepers
4起動kafka
#4.1 zookeeper
zookeeper-server-start.bat ..\config\zookeeper.properties
#4.2 kafka sever, 9092
kafka-server-start.bat ..\config\server.properties
5簡単な使用
#5.1 topic
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic my-test-topic
# topic
kafka-topics.bat --describe --zookeeper localhost:2181 --topic my-test-topic
#5.2 console produre message after enter key
kafka-console-producer.bat --broker-list localhost:9092 --topic my-test-topic
#5.2 console consumer message
kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic my-test-topic
win 10の下で作成して、ソフトリンクの方式を使って経路の問題を避けますhttp://gnarvind.blogspot.kr/2016/12/kafka-windows-10.htmlwin 7で作成して使用http://lehoon.com/backend/2016/08/22/kafka-window.html公式サイトhttp://kafka.apache.org/