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

Commit b7a2ad0

Browse files
Fixed command to start the Streams app -> Now with fat jar which includes all dependencies
1 parent ba7c3b3 commit b7a2ad0

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

‎README.md‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ Let's build the project:
109109
110110
This example executes a Java main method, i.e. it starts a local Java process running the Kafka Streams microservice. It waits continuously for new events arriving at 'ImageInputTopic' to do a model inference (via gRCP call to TensorFlow Serving) and then sending the prediction to 'ImageOutputTopic' - all in real time within milliseconds.
111111

112-
java -cp target/tensorflow-serving-java-grpc-kafka-streams-1.0.jar com.github.megachucky.kafka.streams.machinelearning.Kafka_Streams_TensorFlow_Serving_gRPC_Example
112+
java -cp target/tensorflow-serving-java-grpc-kafka-streams-1.0-jar-with-dependencies.jar com.github.megachucky.kafka.streams.machinelearning.Kafka_Streams_TensorFlow_Serving_gRPC_Example
113113

114114
In the same way, you could deploy this Kafka Streams microservice anywhere - including Kubernetes (e.g. on premise OpenShift cluster or Google Kubernetes Engine), Mesosphere, Amazon ECS or even in a Java EE app - and scale it up and down dynamically.
115115

@@ -120,3 +120,7 @@ Now send messages, e.g. with kafkacat...
120120
... and consume predictions:
121121

122122
kafka-console-consumer --bootstrap-server localhost:9092 --topic ImageOutputTopic --from-beginning
123+
124+
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):
125+
126+
confluent destroy

0 commit comments

Comments
(0)

AltStyle によって変換されたページ (->オリジナル) /