55 lines
993 B
Markdown
55 lines
993 B
Markdown
# Spring Boot Kafka Communication
|
|
|
|
##Commands
|
|
|
|
- Start Zookeeper
|
|
```shell
|
|
bin/zookeeper-server-start.sh config/zookeeper.properties
|
|
```
|
|
- Start Kafka
|
|
```shell
|
|
|
|
```
|
|
- Create Kafka topic
|
|
```shell
|
|
bin/kafka-topics.sh --create \
|
|
--topic first-topic \
|
|
--partitions=4 \
|
|
--replication-factor=1 \
|
|
--bootstrap-server localhost:9092
|
|
```
|
|
|
|
- List Kafka Topics
|
|
```shell
|
|
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
|
|
```
|
|
|
|
- Console consumer
|
|
```shell
|
|
bin/kafka-console-consumer.sh \
|
|
--bootstrap-server localhost:9092 \
|
|
--property key.separator=: \
|
|
--property print.key=true \
|
|
--property print.offset=true \
|
|
--property print.partition=true \
|
|
--property print.value=true \
|
|
--property print.headers=true \
|
|
--topic first-topic \
|
|
--from-beginning \
|
|
--group group1
|
|
```
|
|
|
|
- Console Consumer
|
|
```shell
|
|
bin/kafka-console-producer.sh \
|
|
--bootstrap-server localhost:9092 \
|
|
--property parse.key=true \
|
|
--property key.separator=: \
|
|
--topic first-topic
|
|
```
|
|
|
|
- Payload
|
|
```json
|
|
mykey:"{\"name\": \"Jack\"}"
|
|
```
|