Skip to content

Instantly share code, notes, and snippets.

@confluentgist

confluentgist/configure.java

Forked from kaiwaehner/configure.java
Created October 29, 2019 23:19
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save confluentgist/2bffe26687dd5e4bb0ea1d1369b1c26a to your computer and use it in GitHub Desktop.
Save confluentgist/2bffe26687dd5e4bb0ea1d1369b1c26a to your computer and use it in GitHub Desktop.
Download ZIP
Raw
configure.java
// Configure Kafka Streams Application
final String bootstrapServers = args.length > 0 ? args[0] : "localhost:9092";
final Properties streamsConfiguration = new Properties();
// Give the Streams application a unique name. The name must be unique
// in the Kafka cluster against which the application is run.
streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "kafka-streams-tensorflow-serving-gRPC-example");
// Where to find Kafka broker(s).
streamsConfiguration.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment