Skip to content

Instantly share code, notes, and snippets.

View samhandev's full-sized avatar

Sam Han samhandev

5 followers · 6 following
View GitHub Profile
@samhandev
samhandev / core.clj
Created March 6, 2017 14:15
Based on https://github.com/jameswalton/kafka-streams with explicit creation of objects
(ns kafka-streams-test.core
(:import [org.apache.kafka.streams.kstream KStreamBuilder ValueMapper]
[org.apache.kafka.streams KafkaStreams StreamsConfig]
[org.apache.kafka.common.serialization Serdes])
(:gen-class))
(def props
{StreamsConfig/APPLICATION_ID_CONFIG "dictionary-words-count"
StreamsConfig/BOOTSTRAP_SERVERS_CONFIG "localhost:9092"
StreamsConfig/KEY_SERDE_CLASS_CONFIG (.getName (.getClass (Serdes/String)))
@samhandev
samhandev / keybase.md
Created February 5, 2016 17:11

Keybase proof

I hereby claim:

  • I am samhandev on github.
  • I am samhan (https://keybase.io/samhan) on keybase.
  • I have a public key ASD5nOtfut22p_5a_YUmODjhGsnXics8997DkH9k5-7Fswo

To claim this, I am signing this object: