Kafka Streams Wrapper that simplifies writing topologies

[GalateaWade]

Create an ecosystem around KafkaStreams that gives developer more type-safety as well as getting rid of boilerplate code. Wrapper called GStreams

• GlobalStoreRef<K,V>: object that represents a global store (name, serdes, topicName, and optional processor to capture updates to store when service is live). These stores can be registered in topology with
• TaskStoreRef<K,V>: object that represents a task store (sharded according to consumed partitions) (name, serdes, purgePolicy).
• StoreProvider: allows retrieval of a task or global store. if task store, retrieved store will be task-specific.
• TaskStore<K,V>: wrapper for underlying task store retrieved from kafkaStreams. This is the object returned by StoreProvider when provided a TaskStoreRef.
• GlobalStore<K,V>: wrapper for underlying global store retrieved from kafkaStreams. This is the object returned by StoreProvider when provided a GlobalStoreRef
• TransformStrategy<K, V, K1, V1, T>: represent transformer. Uses @Punctuate annotation to find methods to schedule. interface enforces developer implements init, close, sharedStateInit, transform
• ProcessStrategy<K,V,T>: represent processor. Uses @Punctuate annotation to find methods to schedule.
• use annotations to find task stores to attach to transformer/processor

[GalateaWade]

• Renamed TransformStrategy with TransformerTemplate
• TransformStrategy uses builder, with collections of taskStores and punctuates, instead of using annotations.

[GalateaWade]

Deferred introduction of store expiration policy