Skip to content

Instantly share code, notes, and snippets.

View careykevin's full-sized avatar

Kevin Carey careykevin

View GitHub Profile
@careykevin
careykevin / KafkaStreamsDemoApplication.java
Last active December 19, 2019 16:32
Spring Boot - Kafka Streams example
package com.careykevin.kafkastreamsdemo;
import com.careykevin.kafkastreamsdemo.util.StreamListenerService;
import lombok.RequiredArgsConstructor;
import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.kstream.Grouped;
import org.apache.kafka.streams.kstream.KStream;
import org.apache.kafka.streams.kstream.Materialized;
import org.apache.kafka.streams.state.ReadOnlyKeyValueStore;
import org.springframework.boot.SpringApplication;

Keybase proof

I hereby claim:

  • I am careykevin on github.
  • I am careykevin (https://keybase.io/careykevin) on keybase.
  • I have a public key ASBgII19cmVED3Fz1HBPlNl5W1rIUVzHJ7nAGwhuiEix8Qo

To claim this, I am signing this object: