文件列表:

.mvn/ (0, 2023-11-10)
.mvn/wrapper/ (0, 2023-11-10)
.mvn/wrapper/maven-wrapper.jar (59925, 2023-11-10)
.mvn/wrapper/maven-wrapper.properties (1019, 2023-11-10)
kafka-consumer-database/ (0, 2023-11-10)
kafka-consumer-database/pom.xml (1221, 2023-11-10)
kafka-consumer-database/src/ (0, 2023-11-10)
kafka-consumer-database/src/main/ (0, 2023-11-10)
kafka-consumer-database/src/main/java/ (0, 2023-11-10)
kafka-consumer-database/src/main/java/com/ (0, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/ (0, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/KafkaDatabaseConsumer.java (1043, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/SpringbootConsumerApplication.java (327, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/entity/ (0, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/entity/WikimediaData.java (348, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/repository/ (0, 2023-11-10)
kafka-consumer-database/src/main/java/com/lab/repository/WikimediaDataRepository.java (218, 2023-11-10)
kafka-consumer-database/src/main/resources/ (0, 2023-11-10)
kafka-consumer-database/src/main/resources/application.properties (846, 2023-11-10)
kafka-producer-wikimedia/ (0, 2023-11-10)
kafka-producer-wikimedia/pom.xml (1931, 2023-11-10)
kafka-producer-wikimedia/src/ (0, 2023-11-10)
kafka-producer-wikimedia/src/main/ (0, 2023-11-10)
kafka-producer-wikimedia/src/main/java/ (0, 2023-11-10)
kafka-producer-wikimedia/src/main/java/com/ (0, 2023-11-10)
kafka-producer-wikimedia/src/main/java/com/lab/ (0, 2023-11-10)
kafka-producer-wikimedia/src/main/java/com/lab/KafkaTopicConfig.java (530, 2023-11-10)
kafka-producer-wikimedia/src/main/java/com/lab/SpringbootProducerApplication.java (717, 2023-11-10)
kafka-producer-wikimedia/src/main/java/com/lab/WikimediaChangesHandler.java (1174, 2023-11-10)
kafka-producer-wikimedia/src/main/java/com/lab/WikimediaChangesProducer.java (1328, 2023-11-10)
kafka-producer-wikimedia/src/main/resources/ (0, 2023-11-10)
kafka-producer-wikimedia/src/main/resources/application.properties (385, 2023-11-10)
mvnw (10284, 2023-11-10)
mvnw.cmd (6734, 2023-11-10)
pom.xml (2025, 2023-11-10)
src/ (0, 2023-11-10)
src/main/ (0, 2023-11-10)
src/main/java/ (0, 2023-11-10)
... ...

## Implement Kafka with Springboot and consume Real time Data Resource #### Consume Data URI - Wikimedia url : https://stream.wikimedia.org/v2/stream/recentchange #### How to Run Kafka In this Project use Windows OS #### STEP 1: DOWNLOAD AND INSTALL KAFKA I use Kafka Binary Download in Scala 12.2 : https://kafka.apache.org/downloads
The Guide to use Kafka in this link : https://kafka.apache.org/quickstart #### STEP 2: START THE KAFKA ENVIRONMENT (PRIMARY) Start the ZooKeeper service
`C:\kafka>.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties` Start the Kafka broker service
`C:\kafka>.\bin\windows\kafka-server-start.bat .\config\server.properties` #### STEP 3: CREATE A TOPIC TO STORE YOUR EVENTS (DON'T NEED, Because we create from this project)
`C:\kafka>.\bin\windows\kafka-topics.bat --create --topic wikimedia_recentchange --bootstrap-server localhost:9092` #### STEP 4: WRITE SOME EVENTS INTO THE TOPIC (DON'T NEED, Because we Consume producer from Wikimedia)
`C:\kafka>.\bin\windows\kafka-console-producer.bat --topic wikimedia_recentchange --bootstrap-server localhost:9092` - hello world - topic demo #### STEP 5: READ THE EVENTS (OPTIONAL, If you need check Kafka consumer, but in this project we use Spring logging)
`C:\kafka>.\bin\windows\kafka-console-consumer.bat --topic wikimedia_recentchange --from-beginning --bootstrap-server localhost:9092`

近期下载者：

相关文件：

评论：[我要评论] [举报此文件]

收藏者：