lightbend/kafka-streams-scala

Issues

• Archive this repository

  #78 opened 7 years ago by raboof
  3

• stable URL to publish 'current' API documentation

  #77 opened 7 years ago by raboof
  2

• Kafka 2.0 support

  #76 opened 7 years ago by jorkzijlstra
  2

• kafka streams doesn't rebalance when one broker is down

  #75 opened 7 years ago by yogeshbelur
  1

• Proposal to add Circe support

  #68 opened 7 years ago by joan38
  4

• support for ValueTransformerWithKey

  #72 opened 7 years ago by hashangayasri
  3

• case classes

  #42 opened 8 years ago by mazorigal
  12

• KStreamS#merge is recursive, causing StackOverflow on initialization

  #63 opened 8 years ago by pacman899
  3

• KStream-KTable inner join

  #64 opened 8 years ago by nvladimiroff
  1

• Timestamp extractor not supported

  #62 opened 8 years ago by pacman899
  1

• Question: avro plus Schema Registry?

  #61 opened 8 years ago by MarkRBM
  9

• Move hard coded constants from KafkaLocalServer to config file

  #11 opened 8 years ago by debasishg
  1

• Kafka server utils not being packaged

  #56 opened 8 years ago by MarkRBM
  7

• Implicit Serdes

  #46 opened 8 years ago by maver1ck
  22

• java.lang.ClassCastException for reduce api call

  #57 opened 8 years ago by dnrusakov
  11

• KTable#filter(K,V => Boolean, Materialized) is called recusively on KTableS

  #54 opened 8 years ago by mtranter
  2

• Mockedstreams for unit testing!

  #50 opened 8 years ago by s3ni0r
  2

• StateStore API

  #49 opened 8 years ago by yeenow123
  1

• KGroupedStreamS recursion

  #41 opened 8 years ago by nitayk
  12

• Is 2.11 supported?

  #39 opened 8 years ago
  2

• Setup Travis CI yml

  #29 opened 8 years ago by jiminhsieh
  1

• Issue with KStreams transform returning null

  #35 opened 8 years ago by mtebourbi
  1

• There should be a way to override the StreamBuilder instance present inside the StreamBuilderS for unit testing.

  #33 opened 8 years ago by shiv4nsh
  3

• Without `project/build.properties`

  #28 opened 8 years ago by jiminhsieh
  2

• StreamsBuilderS.globalTable misses overload with Consumed[K, V] as parameter

  #31 opened 8 years ago by jeroenr
  2

• Change unit testing framework from minitest to ScalaTest

  #10 opened 8 years ago by debasishg
  1