Created
April 10, 2017 08:20
-
-
Save ivanursul/42b2312055ab200bd4bba1d4cab5791a to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning \ | |
--topic WordsWithCountsTopic \ | |
--formatter kafka.tools.DefaultMessageFormatter \ | |
--property print.key=true \ | |
--property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \ | |
--property value.deserializer=org.apache.kafka.common.serialization.LongDeserializer | |
all 1 | |
streams 1 | |
lead 1 | |
to 1 | |
kafka 1 | |
hello 1 | |
kafka 2 | |
streams 2 | |
join 1 | |
kafka 3 | |
summit 1 | |
hello 2 | |
my 1 | |
name 1 | |
is 1 | |
ivan 1 | |
and 1 | |
i 1 | |
am 1 | |
learning 1 | |
apache 1 | |
kafka 4 | |
streams 3 | |
hello 3 | |
my 2 | |
name 2 | |
is 2 | |
ivan 2 | |
and 2 | |
i 2 | |
am 2 | |
learning 2 | |
apache 2 | |
kafka 5 | |
streams 4 | |
1 | |
aавіавіаві 1 | |
all 2 | |
streams 5 | |
lead 2 | |
to 2 | |
kafka 6 | |
hello 4 | |
kafka 7 | |
streams 6 | |
join 2 | |
kafka 8 | |
summit 2 | |
all 3 | |
streams 7 | |
lead 3 | |
to 3 | |
kafka 9 | |
hello 5 | |
kafka 10 | |
streams 8 | |
join 3 | |
kafka 11 | |
summit 3 | |
all 4 | |
streams 9 | |
lead 4 | |
to 4 | |
kafka 12 | |
hello 6 | |
kafka 13 | |
streams 10 | |
join 4 | |
kafka 14 | |
summit 4 | |
all 5 | |
streams 11 | |
lead 5 | |
to 5 | |
kafka 15 | |
hello 7 | |
kafka 16 | |
streams 12 | |
join 5 | |
kafka 17 | |
summit 5 | |
fdssdgsdgsd 1 | |
gdfgdfgdf 1 | |
gfdgfdg 1 | |
dgdfgfdgdf 1 | |
hello 8 | |
ivan 3 | |
ursul 1 | |
dsgsdgdfgd 1 | |
gd 1 | |
fdfhsdfh 1 | |
hello 9 | |
world 1 | |
korobok 1 | |
kapusta 1 | |
kapusta 2 | |
ohirok 1 | |
onion 1 | |
harbil 1 | |
azaza 2 | |
azaza 4 | |
azaza 6 | |
ihor 1 | |
dsgdfgfd 1 | |
gfd 1 | |
dfg 1 | |
fdg 3 | |
df 4 | |
gf 1 | |
dg 1 | |
g 14 | |
fd 11 | |
hello 10 | |
world 2 | |
fdsgsdg 1 | |
gdfgdfg 1 | |
gdfgdf 1 | |
hanh 1 | |
gfdgdf 1 | |
dfh 3 | |
hf 1 | |
2 | |
gf 3 | |
fgh 2 | |
hfg 3 | |
h 8 | |
fg 8 | |
hfg 4 | |
azazazaza 1 | |
sdgfdgfdg 1 | |
fdg 4 | |
fd 12 | |
df 6 | |
g 17 | |
3 | |
azazazaza 19 | |
azazazaza 21 | |
hello 11 | |
world 3 | |
ivan 4 | |
baraban 1 | |
baraban 2 | |
ivan 6 | |
ivan 7 | |
baraban 3 | |
ivan 8 | |
baraban 4 | |
ivan 9 | |
baraban 5 | |
ivan 10 | |
baraban 6 | |
4 | |
b 1 | |
ivan 17 | |
baraban 13 | |
ivan 34 | |
baraban 30 | |
fdsfdsg 1 | |
sdg 1 | |
fdg 5 | |
df 9 | |
dfg 3 | |
6 | |
fdh 1 | |
j 2 | |
sa 1 | |
ew 1 | |
twe 1 | |
er 1 | |
g 23 | |
d 1 | |
v 1 | |
cx 1 | |
b 2 | |
vj 1 | |
sj 1 | |
gf 5 | |
jfg 1 | |
ivan 40 | |
null Processed a total of 180 messages |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment