Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit36401c6

Browse files
committed
update readme
1 parentf5e6c07 commit36401c6

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

‎README.md‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,4 +35,24 @@ Send message to broker
3535
$ BROKERS=localhost:9092 TOPIC=demo java -jar target/Producer-1.0-SNAPSHOT.jar
3636
$ Type Message (type'exit' to quit)
3737
$ hello
38+
```
39+
40+
###Run Consumer
41+
```shell
42+
$cd Consumer
43+
```
44+
45+
Build
46+
```shell
47+
$ mvn clean package
48+
```
49+
50+
Receive message from broker
51+
52+
```shell
53+
$ BROKERS=localhost:9092 TOPIC=demo java -jar target/Consumer-1.0-SNAPSHOT.jar
54+
$ Record Key null
55+
$ Record value Product{id='001', name='Nokia 6', quantity=5, images=[wuriyanto.com/img1, wuriyanto.com/img2]}
56+
$ Record partition 49
57+
$ Record offset 0
3858
```

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp