【文件属性】:
文件名称:kafka-streams-sandbox:Apache Kafka流(KStream和KTable)
文件大小:64KB
文件格式:ZIP
更新时间:2021-03-04 16:24:01
streaming kafka kafka-streams kafka-java Java
kafka-streams-sandbox
Apache Kafka流(KStream和KTable)。
docker-compose up -d(或docker-compose up -d-broker:如果不需要架构注册表)
确认与kafka代理的连接:nc -vz localhost 29092
检查Kafka代理的属性和./configuration/dev.properties中的主题
./gradlew clean build shadowJar ./gradlew运行(或调试./gradlew运行--debug-jvm并启动VSCode以侦听端口5005)
检查所有主题:cd ./bin/kafka-topics.sh --bootstrap-server localhost:29092 --list
产生到主题的消息:cd ./bin/kafka-console
【文件预览】:
kafka-streams-sandbox-main
----gradlew(6KB)
----src()
--------main()
----.vscode()
--------launch.json(1KB)
--------settings.json(66B)
----configuration()
--------dev.properties(360B)
----gradle()
--------wrapper()
----README.md(2KB)
----gradlew.bat(3KB)
----docker-compose.yaml(1KB)
----build.gradle(1KB)