로컬 카프카 설치 및 카프카 CLI 실습

PS C:\Users\park7\Downloads> tar -xvzf C:\Users\park7\Downloads\kafka_2.12-2.5.0.tgz -C C:\kafka
x kafka_2.12-2.5.0/
x kafka_2.12-2.5.0/LICENSE
x kafka_2.12-2.5.0/NOTICE
x kafka_2.12-2.5.0/bin/
x kafka_2.12-2.5.0/bin/kafka-delete-records.sh
x kafka_2.12-2.5.0/bin/trogdor.sh
x kafka_2.12-2.5.0/bin/kafka-preferred-replica-election.sh
x kafka_2.12-2.5.0/bin/connect-mirror-maker.sh
x kafka_2.12-2.5.0/bin/kafka-console-consumer.sh
x kafka_2.12-2.5.0/bin/kafka-consumer-perf-test.sh
x kafka_2.12-2.5.0/bin/kafka-log-dirs.sh
x kafka_2.12-2.5.0/bin/zookeeper-server-stop.sh
x kafka_2.12-2.5.0/bin/kafka-verifiable-consumer.sh
x kafka_2.12-2.5.0/bin/kafka-acls.sh
x kafka_2.12-2.5.0/bin/zookeeper-server-start.sh
x kafka_2.12-2.5.0/bin/kafka-server-stop.sh
x kafka_2.12-2.5.0/bin/kafka-configs.sh
x kafka_2.12-2.5.0/bin/kafka-reassign-partitions.sh
x kafka_2.12-2.5.0/bin/kafka-leader-election.sh
x kafka_2.12-2.5.0/bin/kafka-producer-perf-test.sh
x kafka_2.12-2.5.0/bin/kafka-topics.sh
x kafka_2.12-2.5.0/bin/connect-standalone.sh
x kafka_2.12-2.5.0/bin/kafka-dump-log.sh
x kafka_2.12-2.5.0/bin/kafka-broker-api-versions.sh
x kafka_2.12-2.5.0/bin/kafka-consumer-groups.sh
x kafka_2.12-2.5.0/bin/connect-distributed.sh
x kafka_2.12-2.5.0/bin/kafka-delegation-tokens.sh
x kafka_2.12-2.5.0/bin/kafka-run-class.sh
x kafka_2.12-2.5.0/bin/kafka-replica-verification.sh
x kafka_2.12-2.5.0/bin/kafka-console-producer.sh
x kafka_2.12-2.5.0/bin/zookeeper-shell.sh
x kafka_2.12-2.5.0/bin/windows/
x kafka_2.12-2.5.0/bin/windows/kafka-log-dirs.bat
x kafka_2.12-2.5.0/bin/windows/zookeeper-server-stop.bat
x kafka_2.12-2.5.0/bin/windows/connect-distributed.bat
x kafka_2.12-2.5.0/bin/windows/kafka-configs.bat
x kafka_2.12-2.5.0/bin/windows/kafka-console-producer.bat
x kafka_2.12-2.5.0/bin/windows/kafka-delete-records.bat
x kafka_2.12-2.5.0/bin/windows/kafka-topics.bat
x kafka_2.12-2.5.0/bin/windows/kafka-dump-log.bat
x kafka_2.12-2.5.0/bin/windows/kafka-console-consumer.bat
x kafka_2.12-2.5.0/bin/windows/kafka-preferred-replica-election.bat
x kafka_2.12-2.5.0/bin/windows/kafka-server-start.bat
x kafka_2.12-2.5.0/bin/windows/kafka-consumer-groups.bat
x kafka_2.12-2.5.0/bin/windows/kafka-mirror-maker.bat
x kafka_2.12-2.5.0/bin/windows/kafka-reassign-partitions.bat
x kafka_2.12-2.5.0/bin/windows/kafka-producer-perf-test.bat
x kafka_2.12-2.5.0/bin/windows/zookeeper-server-start.bat
x kafka_2.12-2.5.0/bin/windows/kafka-server-stop.bat
x kafka_2.12-2.5.0/bin/windows/kafka-replica-verification.bat
x kafka_2.12-2.5.0/bin/windows/kafka-run-class.bat
x kafka_2.12-2.5.0/bin/windows/kafka-acls.bat
x kafka_2.12-2.5.0/bin/windows/kafka-delegation-tokens.bat
x kafka_2.12-2.5.0/bin/windows/kafka-broker-api-versions.bat
x kafka_2.12-2.5.0/bin/windows/kafka-leader-election.bat
x kafka_2.12-2.5.0/bin/windows/kafka-streams-application-reset.bat
x kafka_2.12-2.5.0/bin/windows/zookeeper-shell.bat
x kafka_2.12-2.5.0/bin/windows/connect-standalone.bat
x kafka_2.12-2.5.0/bin/windows/kafka-consumer-perf-test.bat
x kafka_2.12-2.5.0/bin/kafka-verifiable-producer.sh
x kafka_2.12-2.5.0/bin/kafka-server-start.sh
x kafka_2.12-2.5.0/bin/kafka-mirror-maker.sh
x kafka_2.12-2.5.0/bin/kafka-streams-application-reset.sh
x kafka_2.12-2.5.0/bin/zookeeper-security-migration.sh
x kafka_2.12-2.5.0/config/
x kafka_2.12-2.5.0/config/consumer.properties
x kafka_2.12-2.5.0/config/connect-mirror-maker.properties
x kafka_2.12-2.5.0/config/zookeeper.properties
x kafka_2.12-2.5.0/config/server.properties
x kafka_2.12-2.5.0/config/producer.properties
x kafka_2.12-2.5.0/config/trogdor.conf
x kafka_2.12-2.5.0/config/connect-console-sink.properties
x kafka_2.12-2.5.0/config/connect-log4j.properties
x kafka_2.12-2.5.0/config/connect-standalone.properties
x kafka_2.12-2.5.0/config/connect-file-source.properties
x kafka_2.12-2.5.0/config/connect-console-source.properties
x kafka_2.12-2.5.0/config/connect-distributed.properties
x kafka_2.12-2.5.0/config/tools-log4j.properties
x kafka_2.12-2.5.0/config/connect-file-sink.properties
x kafka_2.12-2.5.0/config/log4j.properties
x kafka_2.12-2.5.0/libs/
x kafka_2.12-2.5.0/libs/kafka-clients-2.5.0.jar
x kafka_2.12-2.5.0/libs/jackson-module-scala_2.12-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-dataformat-csv-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-datatype-jdk8-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-module-paranamer-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-databind-2.10.2.jar
x kafka_2.12-2.5.0/libs/jopt-simple-5.0.4.jar
x kafka_2.12-2.5.0/libs/metrics-core-2.2.0.jar
x kafka_2.12-2.5.0/libs/scala-collection-compat_2.12-2.1.3.jar
x kafka_2.12-2.5.0/libs/scala-java8-compat_2.12-0.9.0.jar
x kafka_2.12-2.5.0/libs/scala-logging_2.12-3.9.2.jar
x kafka_2.12-2.5.0/libs/scala-reflect-2.12.10.jar
x kafka_2.12-2.5.0/libs/scala-library-2.12.10.jar
x kafka_2.12-2.5.0/libs/zookeeper-3.5.7.jar
x kafka_2.12-2.5.0/libs/slf4j-api-1.7.30.jar
x kafka_2.12-2.5.0/libs/commons-cli-1.4.jar
x kafka_2.12-2.5.0/libs/zstd-jni-1.4.4-7.jar
x kafka_2.12-2.5.0/libs/lz4-java-1.7.1.jar
x kafka_2.12-2.5.0/libs/snappy-java-1.1.7.3.jar
x kafka_2.12-2.5.0/libs/jackson-annotations-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-core-2.10.2.jar
x kafka_2.12-2.5.0/libs/zookeeper-jute-3.5.7.jar
x kafka_2.12-2.5.0/libs/audience-annotations-0.5.0.jar
x kafka_2.12-2.5.0/libs/netty-handler-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/netty-transport-native-epoll-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/paranamer-2.8.jar
x kafka_2.12-2.5.0/libs/netty-codec-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/netty-transport-native-unix-common-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/netty-transport-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/netty-buffer-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/netty-resolver-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/netty-common-4.1.45.Final.jar
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0.jar
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0.jar.asc
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-sources.jar.asc
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-javadoc.jar.asc
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-test.jar.asc
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-test-sources.jar.asc
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-scaladoc.jar.asc
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-sources.jar
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-javadoc.jar
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-test.jar
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-test-sources.jar
x kafka_2.12-2.5.0/libs/kafka_2.12-2.5.0-scaladoc.jar
x kafka_2.12-2.5.0/site-docs/
x kafka_2.12-2.5.0/site-docs/kafka_2.12-2.5.0-site-docs.tgz
x kafka_2.12-2.5.0/libs/kafka-tools-2.5.0.jar
x kafka_2.12-2.5.0/libs/kafka-log4j-appender-2.5.0.jar
x kafka_2.12-2.5.0/libs/argparse4j-0.7.0.jar
x kafka_2.12-2.5.0/libs/jackson-jaxrs-json-provider-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-jaxrs-base-2.10.2.jar
x kafka_2.12-2.5.0/libs/jackson-module-jaxb-annotations-2.10.2.jar
x kafka_2.12-2.5.0/libs/slf4j-log4j12-1.7.30.jar
x kafka_2.12-2.5.0/libs/jersey-container-servlet-2.28.jar
x kafka_2.12-2.5.0/libs/jersey-hk2-2.28.jar
x kafka_2.12-2.5.0/libs/jaxb-api-2.3.0.jar
x kafka_2.12-2.5.0/libs/activation-1.1.1.jar
x kafka_2.12-2.5.0/libs/jetty-servlet-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jetty-security-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jetty-server-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jetty-servlets-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jersey-container-servlet-core-2.28.jar
x kafka_2.12-2.5.0/libs/jersey-server-2.28.jar
x kafka_2.12-2.5.0/libs/jersey-client-2.28.jar
x kafka_2.12-2.5.0/libs/jersey-media-jaxb-2.28.jar
x kafka_2.12-2.5.0/libs/jersey-common-2.28.jar
x kafka_2.12-2.5.0/libs/jakarta.ws.rs-api-2.1.5.jar
x kafka_2.12-2.5.0/libs/hk2-locator-2.5.0.jar
x kafka_2.12-2.5.0/libs/javax.servlet-api-3.1.0.jar
x kafka_2.12-2.5.0/libs/jetty-http-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jetty-io-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jetty-continuation-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/jetty-util-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/log4j-1.2.17.jar
x kafka_2.12-2.5.0/libs/jakarta.xml.bind-api-2.3.2.jar
x kafka_2.12-2.5.0/libs/jakarta.activation-api-1.2.1.jar
x kafka_2.12-2.5.0/libs/hk2-api-2.5.0.jar
x kafka_2.12-2.5.0/libs/hk2-utils-2.5.0.jar
x kafka_2.12-2.5.0/libs/osgi-resource-locator-1.0.1.jar
x kafka_2.12-2.5.0/libs/validation-api-2.0.1.Final.jar
x kafka_2.12-2.5.0/libs/aopalliance-repackaged-2.5.0.jar
x kafka_2.12-2.5.0/libs/javassist-3.22.0-CR2.jar
x kafka_2.12-2.5.0/libs/connect-api-2.5.0.jar
x kafka_2.12-2.5.0/libs/javax.ws.rs-api-2.1.1.jar
x kafka_2.12-2.5.0/libs/connect-runtime-2.5.0.jar
x kafka_2.12-2.5.0/libs/connect-json-2.5.0.jar
x kafka_2.12-2.5.0/libs/connect-transforms-2.5.0.jar
x kafka_2.12-2.5.0/libs/jetty-client-9.4.24.v20191120.jar
x kafka_2.12-2.5.0/libs/reflections-0.9.12.jar
x kafka_2.12-2.5.0/libs/maven-artifact-3.6.3.jar
x kafka_2.12-2.5.0/libs/javassist-3.26.0-GA.jar
x kafka_2.12-2.5.0/libs/plexus-utils-3.2.1.jar
x kafka_2.12-2.5.0/libs/commons-lang3-3.8.1.jar
x kafka_2.12-2.5.0/libs/connect-basic-auth-extension-2.5.0.jar
x kafka_2.12-2.5.0/libs/connect-mirror-2.5.0.jar
x kafka_2.12-2.5.0/libs/connect-mirror-client-2.5.0.jar
x kafka_2.12-2.5.0/libs/kafka-streams-2.5.0.jar
x kafka_2.12-2.5.0/libs/rocksdbjni-5.18.3.jar
x kafka_2.12-2.5.0/libs/kafka-streams-scala_2.12-2.5.0.jar
x kafka_2.12-2.5.0/libs/kafka-streams-test-utils-2.5.0.jar
x kafka_2.12-2.5.0/libs/kafka-streams-examples-2.5.0.jar
PS C:\Users\park7\Downloads> cd C:\kafka\kafka_2.12-2.5.0
PS C:\kafka\kafka_2.12-2.5.0> ls

    디렉터리: C:\kafka\kafka_2.12-2.5.0


Mode                 LastWriteTime         Length Name
----                 -------------         ------ ----
d-----      2020-04-08  오전 10:16                bin
d-----      2020-04-08  오전 10:16                config
d-----      2020-04-08  오전 10:16                libs
d-----      2020-04-08  오전 10:16                site-docs
-a----      2020-04-08  오전 10:13          32216 LICENSE
-a----      2020-04-08  오전 10:13            337 NOTICE


PS C:\kafka\kafka_2.12-2.5.0> mkdir data


    디렉터리: C:\kafka\kafka_2.12-2.5.0


Mode                 LastWriteTime         Length Name
----                 -------------         ------ ----
d-----      2023-09-30   오후 9:02                data


PS C:\kafka\kafka_2.12-2.5.0> ls


    디렉터리: C:\kafka\kafka_2.12-2.5.0


Mode                 LastWriteTime         Length Name
----                 -------------         ------ ----
d-----      2020-04-08  오전 10:16                bin
d-----      2020-04-08  오전 10:16                config
d-----      2023-09-30   오후 9:02                data
d-----      2020-04-08  오전 10:16                libs
d-----      2020-04-08  오전 10:16                site-docs
-a----      2020-04-08  오전 10:13          32216 LICENSE
-a----      2020-04-08  오전 10:13            337 NOTICE

 

(카프카 주키퍼 실행)

PS C:\kafka\kafka_2.12-2.5.0> bin/zookeeper-server-start.sh config/zookeeper.properties

 

(카프카 브로커 실행)

PS C:\kafka\kafka_2.12-2.5.0> bin/kafka-server-start.sh config/server.properties

 

(카프카 정상 실행 여부 확인)

PS C:\kafka\kafka_2.12-2.5.0> bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092