kafka-streams-scala icon indicating copy to clipboard operation
kafka-streams-scala copied to clipboard

Published 20 hours ago • verified publisher icon lightbend
→

Metadata

Thin Scala wrapper around Kafka Streams Java API

Results 6 kafka-streams-scala issues
Sort by recently updated
recently updated
newest added

kafka streams doesn't rebalance when one broker is down

1 comment

I am using 0.11.0 streams I have 3 nodes running kafka cluster of 3 broker and i am running the 3 kafka stream with same application.id each node has one...

yogeshbelur avatar yogeshbelur

support for ValueTransformerWithKey

3 comment

Currently, KStreamS#transformValues only has support for ValueTransformer. ValueTransformerWithKey support is needed.

hashangayasri avatar hashangayasri

Scalish

4 comment

Scala version https://github.com/ouertani/kafka-streams-scala/blob/scalish/src/main/scala/com/lightbend/kafka/scala/streams/KafkaStreamsS.scala of KafkaStreams

ouertani avatar ouertani

case classes

12 comment

Hi, is there any example how to use kafka-streams-scala with case classes ? Thanks,

mazorigal avatar mazorigal

Timestamp extractor not supported

1 comment

The `Consumed` class can be provided with `TimstampExtractor`. I suggest add this to the wrapper API.

pacman899 avatar pacman899

StateStore API

1 comment

Any plans to include the state store API in this project?

yeenow123 avatar yeenow123

← Metadata

191
Stars
51
Forks
Watchers

Owner

verified publisher icon lightbend

Metadata

Thin Scala wrapper around Kafka Streams Java API

Back