Skip to content

Commit 955e5ed

Browse files
committed
Updated to Apache Kafka version 2.2
1 parent 78de112 commit 955e5ed

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

README.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ This architecture allows deployement and managend of different models and versio
4545
### Requirements
4646
- Install Java 8
4747
- Install Docker
48-
- Kafka Streams API 2.1 (configured in pom.xml and downloaded via Maven bulid; Kafka Streams API 2.0 and 1.1 are also compatible)
48+
- Kafka Streams API 2.2 (configured in pom.xml and downloaded via Maven build; Kafka Streams API 2.1, 2.0 and 1.1 are also compatible)
4949

5050
The code is developed and tested on Mac and Linux operating systems. As Kafka does not support and work well on Windows, this is not tested at all.
5151

@@ -125,10 +125,10 @@ Now send messages, e.g. with kafkacat...
125125

126126
echo -e "src/main/resources/example.jpg" | kafkacat -b localhost:9092 -P -t ImageInputTopic
127127
128-
... and consume predictions:
128+
... and consume predictions (start consumer first if you want to see the 'real time' processing):
129129

130130
kafka-console-consumer --bootstrap-server localhost:9092 --topic ImageOutputTopic --from-beginning
131131
132-
To stop everything, stop the Docker container with TensorFlow Serving, stop the Kafka Consumer, and finally stop Kafka using using Confluent CLI (which also deletes all configuration and topics):
132+
To stop everything, *stop the Docker container with TensorFlow Serving*, *stop the Kafka Consumer*, and finally stop Kafka using using Confluent CLI (which also deletes all configuration and topics):
133133

134134
confluent destroy

0 commit comments

Comments
 (0)