mjsax

Keybase proof

I hereby claim:

• I am mjsax on github.
• I am mjsax (https://keybase.io/mjsax) on keybase.
• I have a public key ASAQAkOsIzWsJ7-cOgIO0uSczhKB2zbSMUKsnR3oiTNeZQo

To claim this, I am signing this object:

mjsax

# After stopping all application instances, reset the application
$ bin/kafka-streams-application-reset --application-id my-streams-app \
                                      --input-topics my-input-topic \
                                      --intermediate-topics rekeyed-topic \
                                      --bootstrap-servers brokerHost:9092 \
                                      --zookeeper zookeeperHost:2181

mjsax

# Run your application
# For the sake of this short blog post we use the Kafka helper script
# `kafka-run-class` here, but your mileage may vary.
# You could also, for example, call `java …` directly. Remember that
# an application that uses the Kafka Streams library is a standard Java application.
$ bin/kafka-run-class io.confluent.examples.streams.ResetDemo

mjsax

package io.confluent.examples.streams;

// ...some imports...

public class ResetDemo {

    public static void main(final String[] args) throws Exception {
         // ...prepare your application configuration and processing topology...

        final KafkaStreams streams = new KafkaStreams(builder, streamsConfiguration);

mjsax

package io.confluent.examples.streams;

// ...some imports...

public class ResetDemo {

    public static void main(final String[] args) throws Exception {
        // Kafka Streams configuration
        final Properties streamsConfiguration = new Properties();
        streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-streams-app");