Skip to content

issues Search Results · repo:lightbend/kafka-streams-scala language:Scala

Filter by

26 results
 (70 ms)

26 results

inlightbend/kafka-streams-scala (press backspace or delete to remove)

lightbend/kafka-streams-scala
Archive this repository

Since it has been included upstream https://github.blog/2017-11-08-archiving-repositories/
  • raboof
  • 3
  • Opened 
    on Mar 14, 2019
  • #78

lightbend/kafka-streams-scala
stable URL to publish 'current' API documentation

API documentation is now available at https://developer.lightbend.com/docs/api/kafka-streams-scala/0.2.1/com/lightbend/kafka/scala/streams/ , but that URL is tied to version 0.2.1. It would be nice to ...
  • raboof
  • 2
  • Opened 
    on Mar 13, 2019
  • #77

lightbend/kafka-streams-scala
Kafka 2.0 support

We would to use this library in combination with Kafka 2.0 which currently isn t possible.
  • jorkzijlstra
  • 2
  • Opened 
    on Oct 23, 2018
  • #76

lightbend/kafka-streams-scala
kafka streams doesn't rebalance when one broker is down

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 broker one kafka stream application everything ...
  • yogeshbelur
  • 1
  • Opened 
    on Jul 26, 2018
  • #75

lightbend/kafka-streams-scala
support for ValueTransformerWithKey

Currently, KStreamS#transformValues only has support for ValueTransformer. ValueTransformerWithKey support is needed.
  • hashangayasri
  • 3
  • Opened 
    on Jun 21, 2018
  • #72

lightbend/kafka-streams-scala
Proposal to add Circe support

Hi, For the people using Circe with Kafka Streams I have created a little Serde adapter: https://github.com/joan38/kafka-streams-circe This is way too tiny to be in a separate repo on it s own so I was ...
  • joan38
  • 4
  • Opened 
    on Apr 30, 2018
  • #68

lightbend/kafka-streams-scala
KStream-KTable inner join

Is there a reason that KSteamS#join is a left join instead of an inner join? Given that Kafka is pretty consistent that join is an inner join, I m a little confused why kafka-streams-scala s join calls ...
  • nvladimiroff
  • 1
  • Opened 
    on Mar 27, 2018
  • #64

lightbend/kafka-streams-scala
KStreamS#merge is recursive, causing StackOverflow on initialization

def merge(stream: KStreamS[K, V]): KStreamS[K, V] = inner.merge(stream) this is the definition of KStreamS#merge which causes stackoverflow. I think the cause is that the inner KStream instance is getting ...
  • pacman899
  • 3
  • Opened 
    on Mar 25, 2018
  • #63

lightbend/kafka-streams-scala
Timestamp extractor not supported

The Consumed class can be provided with TimstampExtractor. I suggest add this to the wrapper API.
  • pacman899
  • 1
  • Opened 
    on Mar 25, 2018
  • #62

lightbend/kafka-streams-scala
Question: avro plus Schema Registry?

I notice with this pr that you have an example on working with avro specifically with Avro4s, https://github.com/lightbend/kafka-streams-scala/pull/59 . I am wondering if there is any expectation that ...
  • MarkRBM
  • 9
  • Opened 
    on Mar 14, 2018
  • #61
Issue origami icon

Learn how you can use GitHub Issues to plan and track your work.

Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub Issues
ProTip! 
Press the
/
key to activate the search input again and adjust your query.
Issue origami icon

Learn how you can use GitHub Issues to plan and track your work.

Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub Issues
ProTip! 
Restrict your search to the title by using the in:title qualifier.
Issue search results · GitHub