Skip to content

Instantly share code, notes, and snippets.

@confluentgist

confluentgist/config.java

Forked from kaiwaehner/config.java
Created October 29, 2019 23:42
Show Gist options
  • Save confluentgist/c92f9ff6c596b146a2b1f0022d2cd110 to your computer and use it in GitHub Desktop.
Save confluentgist/c92f9ff6c596b146a2b1f0022d2cd110 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
config.java
// Configure Kafka Streams Application
Properties streamsConfiguration = new Properties();
streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "kafka-streams-tensorflow-keras-integration-test");
streamsConfiguration.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers());
// Specify default (de)serializers for record keys and for record values
streamsConfiguration.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
streamsConfiguration.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment