hashangayasri

Wrote an extension to support it ``` // Add ValueTransformerWithKeySupplier import com.lightbend.kafka.scala.streams.KStreamS implicit class KStreamSWithValueTransformerKey[K,V](inner: KStreamS[K,V]) extends KStreamS[K,V](inner.inner){ def transformValuesWithKey[VR](valueTransformerSupplierWithKey: () => ValueTransformerWithKey[K, V, VR], stateStoreNames: String*): KStreamS[K, VR] =...

Not submitting a pull request since this only applies to Kafka 1.1.0 and the current branches are for Kafka 1.0.0. Let me know if a branch for Kafka 1.1.0 is...

> `CHARIBEFS_PORT` -> `CHARYBDEFS_PORT` Resolved

Is this still WIP? What's preventing this from being merged?