【文件属性】:
文件名称:examples:运行 Confluent Platform 的示例代码
文件大小:13KB
文件格式:ZIP
更新时间:2021-06-10 16:16:58
Java
例子
此存储库包括演示如何使用 Java Kafka 生产者和消费者的项目。 您可以在 Confluent Platform 文档的找到代码的详细说明。
构建生产者项目
$ cd producer
$ mvn clean package
构建消费者项目
$ cd consumer
$ mvn clean package
快速开始
在运行示例之前,请确保 Zookeeper、Kafka 和 Schema Registry 正在运行。 接下来,我们假设 Zookeeper、Kafka 和 Schema Registry 以默认设置启动。
# Start Zookeeper
$ bin/zookeeper-server-start config/zookeeper.properties
# Start Kafka
$ bin/kafka-server-start config/serv
【文件预览】:
examples-master
----.gitignore(20B)
----producer()
--------src()
--------pom.xml(2KB)
----README.md(2KB)
----consumer()
--------src()
--------pom.xml(2KB)