example-kafkastreams

example-kafkastreams copied to clipboard

Port code to kafka-streams-scala ( lightbend )

2

Do you think, Code would be more readable using https://github.com/lightbend/kafka-streams-scala ?

ShahSunny

possible PR for stricter types (Processor API) for stores

2

Hiding Strings in distinct types that we'd use internally would help. In code we use `evpv-store` and `pv-store` only once as Strings and immediately to hide them in distinct classes....

phderome

With this and a few more minor changes ```scala daemonThread { sleep(3.seconds) // scalastyle:off startStreams(deduplicate(Serdes.String(), Serdes.String())) } ``` I can change ```scala Stores.windowStoreBuilder( Stores.persistentWindowStore(storeName, retention, segments, window, retainDuplicates), Serdes.String(), Serdes.String()...

phderome