Skip to content

Instantly share code, notes, and snippets.

@vietdoox
vietdoox / TableJoinKafkaStream.java
Created February 23, 2017 07:40 — forked from timothyrenner/TableJoinKafkaStream.java
Example of KTable-KTable join in Kafka Streams
package io.github.timothyrenner.kstreamex.tablejoin;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.KeyValue;
import org.apache.kafka.streams.StreamsConfig;
import org.apache.kafka.streams.kstream.KStream;
@vietdoox
vietdoox / gist:a95090167674dd304eb0cb1e66ff50eb
Created February 1, 2017 07:51 — forked from debasishg/gist:8172796
A collection of links for streaming algorithms and data structures
  1. General Background and Overview