lightbend/kafka-streams-scala issues and pull requests

#78 - Archive this repository

Issue - State: closed - Opened by raboof over 5 years ago - 3 comments

#77 - stable URL to publish 'current' API documentation

Issue - State: closed - Opened by raboof over 5 years ago - 2 comments

#76 - Kafka 2.0 support

Issue - State: closed - Opened by jorkzijlstra over 5 years ago - 2 comments

#75 - kafka streams doesn't rebalance when one broker is down

Issue - State: open - Opened by yogeshbelur almost 6 years ago - 1 comment

#75 - kafka streams doesn't rebalance when one broker is down

Issue - State: open - Opened by yogeshbelur almost 6 years ago - 1 comment

#74 - Long to SessionWindows implicit conversion

Pull Request - State: closed - Opened by teivah almost 6 years ago - 1 comment

#73 - use Scala 2.11.12 in Travis build

Pull Request - State: closed - Opened by sullis almost 6 years ago - 3 comments

#73 - use Scala 2.11.12 in Travis build

Pull Request - State: closed - Opened by sullis almost 6 years ago - 3 comments

#72 - support for ValueTransformerWithKey

Issue - State: open - Opened by hashangayasri about 6 years ago - 3 comments

#72 - support for ValueTransformerWithKey

Issue - State: open - Opened by hashangayasri about 6 years ago - 3 comments

#71 - minor typo in README

Pull Request - State: closed - Opened by sv3ndk about 6 years ago - 1 comment

#71 - minor typo in README

Pull Request - State: closed - Opened by sv3ndk about 6 years ago - 1 comment

#70 - Make Serdes less confusing

Pull Request - State: closed - Opened by joan38 about 6 years ago - 3 comments

#69 - Make things more consistant and add Materialized helper with implicit Serdes

Pull Request - State: closed - Opened by joan38 about 6 years ago - 9 comments

#68 - Proposal to add Circe support

Issue - State: closed - Opened by joan38 about 6 years ago - 4 comments

#67 - Scalafmt?

Pull Request - State: closed - Opened by joan38 about 6 years ago - 3 comments

#67 - Scalafmt?

Pull Request - State: closed - Opened by joan38 about 6 years ago - 3 comments

#66 - Scalish

Pull Request - State: open - Opened by ouertani about 6 years ago - 4 comments

#65 - Miscellaneous fixes

Pull Request - State: closed - Opened by debasishg about 6 years ago

#65 - Miscellaneous fixes

Pull Request - State: closed - Opened by debasishg about 6 years ago

#64 - KStream-KTable inner join

Issue - State: closed - Opened by nvladimiroff over 6 years ago - 1 comment

#64 - KStream-KTable inner join

Issue - State: closed - Opened by nvladimiroff over 6 years ago - 1 comment

#63 - KStreamS#merge is recursive, causing StackOverflow on initialization

Issue - State: closed - Opened by pacman899 over 6 years ago - 3 comments

#62 - Timestamp extractor not supported

Issue - State: open - Opened by pacman899 over 6 years ago - 1 comment

#61 - Question: avro plus Schema Registry?

Issue - State: closed - Opened by MarkRBM over 6 years ago - 9 comments

#61 - Question: avro plus Schema Registry?

Issue - State: closed - Opened by MarkRBM over 6 years ago - 9 comments

#60 - Updated README

Pull Request - State: closed - Opened by debasishg over 6 years ago

#60 - Updated README

Pull Request - State: closed - Opened by debasishg over 6 years ago

#59 - Made implementation completely typesafe - no more default serde with config

Pull Request - State: closed - Opened by debasishg over 6 years ago

#58 - Fix KGroupedStream#reduce to ensure proper serialization

Pull Request - State: closed - Opened by debasishg over 6 years ago

#58 - Fix KGroupedStream#reduce to ensure proper serialization

Pull Request - State: closed - Opened by debasishg over 6 years ago

#57 - java.lang.ClassCastException for reduce api call

Issue - State: closed - Opened by dnrusakov over 6 years ago - 11 comments

#56 - Kafka server utils not being packaged

Issue - State: closed - Opened by MarkRBM over 6 years ago - 7 comments

#56 - Kafka server utils not being packaged

Issue - State: closed - Opened by MarkRBM over 6 years ago - 7 comments

#55 - Force (K,V)=>Boolean to Predicate<K,V> in KTableS

Pull Request - State: closed - Opened by mtranter over 6 years ago - 1 comment

#55 - Force (K,V)=>Boolean to Predicate<K,V> in KTableS

Pull Request - State: closed - Opened by mtranter over 6 years ago - 1 comment

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

Issue - State: closed - Opened by mtranter over 6 years ago - 2 comments

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

Issue - State: closed - Opened by mtranter over 6 years ago - 2 comments

#53 - Kafka streams scala/develop/introduce scalastyle

Pull Request - State: closed - Opened by abdheshkumar over 6 years ago - 3 comments

#52 - Add a typesafe-by-default implementation for kafka-streams-scala

Pull Request - State: closed - Opened by ssaavedra over 6 years ago - 16 comments

#52 - Add a typesafe-by-default implementation for kafka-streams-scala

Pull Request - State: closed - Opened by ssaavedra over 6 years ago - 16 comments

#51 - Implement implicit serde for join and leftJoin

Pull Request - State: closed - Opened by debasishg over 6 years ago

#50 - Mockedstreams for unit testing!

Issue - State: closed - Opened by s3ni0r over 6 years ago - 2 comments

#50 - Mockedstreams for unit testing!

Issue - State: closed - Opened by s3ni0r over 6 years ago - 2 comments

#49 - StateStore API

Issue - State: open - Opened by yeenow123 over 6 years ago - 1 comment

#48 - Updated README with details of implicit serde implementation

Pull Request - State: closed - Opened by debasishg over 6 years ago

#47 - Implementation of Implicit (De-)Serializer techniques

Pull Request - State: closed - Opened by debasishg over 6 years ago

#47 - Implementation of Implicit (De-)Serializer techniques

Pull Request - State: closed - Opened by debasishg over 6 years ago

#46 - Implicit Serdes

Issue - State: closed - Opened by maver1ck over 6 years ago - 22 comments

#46 - Implicit Serdes

Issue - State: closed - Opened by maver1ck over 6 years ago - 22 comments

#45 - Added support for processor APIs and a test for it using punctuator

Pull Request - State: closed - Opened by blublinsky over 6 years ago - 1 comment

#45 - Added support for processor APIs and a test for it using punctuator

Pull Request - State: closed - Opened by blublinsky over 6 years ago - 1 comment

#44 - Fixed annoying warning

Pull Request - State: closed - Opened by blublinsky over 6 years ago

#43 - Explicit SAM conversions for Scala 2.11

Pull Request - State: closed - Opened by debasishg over 6 years ago

#43 - Explicit SAM conversions for Scala 2.11

Pull Request - State: closed - Opened by debasishg over 6 years ago

#42 - case classes

Issue - State: open - Opened by mazorigal over 6 years ago - 12 comments

#41 - KGroupedStreamS recursion

Issue - State: closed - Opened by nitayk over 6 years ago - 12 comments

#41 - KGroupedStreamS recursion

Issue - State: closed - Opened by nitayk over 6 years ago - 12 comments

#40 - Implicit Serdes

Pull Request - State: closed - Opened by svroonland over 6 years ago - 4 comments

#39 - Is 2.11 supported?

Issue - State: closed - Opened by ghost over 6 years ago - 2 comments

#39 - Is 2.11 supported?

Issue - State: closed - Opened by ghost over 6 years ago - 2 comments

#38 - remove unused imports

Pull Request - State: closed - Opened by xuwei-k over 6 years ago - 1 comment

#38 - remove unused imports

Pull Request - State: closed - Opened by xuwei-k over 6 years ago - 1 comment

#37 - add .travis.yml

Pull Request - State: closed - Opened by xuwei-k over 6 years ago

#37 - add .travis.yml

Pull Request - State: closed - Opened by xuwei-k over 6 years ago

#36 - Fix Issue 35 : Manage null results from transform function.

Pull Request - State: closed - Opened by mtebourbi over 6 years ago - 1 comment

#36 - Fix Issue 35 : Manage null results from transform function.

Pull Request - State: closed - Opened by mtebourbi over 6 years ago - 1 comment

#35 - Issue with KStreams transform returning null

Issue - State: closed - Opened by mtebourbi over 6 years ago - 1 comment

#35 - Issue with KStreams transform returning null

Issue - State: closed - Opened by mtebourbi over 6 years ago - 1 comment

#34 - Issue 33 : Added additional constructor for passing an instance of StreamBuilder

Pull Request - State: closed - Opened by shiv4nsh over 6 years ago - 9 comments

#34 - Issue 33 : Added additional constructor for passing an instance of StreamBuilder

Pull Request - State: closed - Opened by shiv4nsh over 6 years ago - 9 comments

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

Issue - State: closed - Opened by shiv4nsh over 6 years ago - 3 comments

#32 - Fixes issue https://github.com/lightbend/kafka-streams-scala/issues/31

Pull Request - State: closed - Opened by debasishg over 6 years ago

#32 - Fixes issue https://github.com/lightbend/kafka-streams-scala/issues/31

Pull Request - State: closed - Opened by debasishg over 6 years ago

#31 - StreamsBuilderS.globalTable misses overload with Consumed[K, V] as parameter

Issue - State: closed - Opened by jeroenr over 6 years ago - 2 comments

#30 - Modifying signature of KStreamS.peek

Pull Request - State: closed - Opened by kpmeen over 6 years ago - 3 comments

#30 - Modifying signature of KStreamS.peek

Pull Request - State: closed - Opened by kpmeen over 6 years ago - 3 comments

#29 - Setup Travis CI yml

Issue - State: closed - Opened by jiminhsieh over 6 years ago - 1 comment

#29 - Setup Travis CI yml

Issue - State: closed - Opened by jiminhsieh over 6 years ago - 1 comment

#28 - Without `project/build.properties`

Issue - State: closed - Opened by jiminhsieh over 6 years ago - 2 comments

#27 - Added copyright info, updated README

Pull Request - State: closed - Opened by debasishg over 6 years ago

#27 - Added copyright info, updated README

Pull Request - State: closed - Opened by debasishg over 6 years ago

#26 - Added some code documentation, updated version to 0.1.0

Pull Request - State: closed - Opened by debasishg over 6 years ago

#25 - Added publish commands to build. Now publishes to Sonatype.

Pull Request - State: closed - Opened by debasishg over 6 years ago - 1 comment

#24 - Added "-mem 1500" flags to SBT commands. Other refinements.

Pull Request - State: closed - Opened by deanwampler over 6 years ago - 3 comments

#24 - Added "-mem 1500" flags to SBT commands. Other refinements.

Pull Request - State: closed - Opened by deanwampler over 6 years ago - 3 comments

#23 - Remove kafka scala query to separate repository

Pull Request - State: closed - Opened by debasishg over 6 years ago

#23 - Remove kafka scala query to separate repository

Pull Request - State: closed - Opened by debasishg over 6 years ago

#22 - The proc example application now runs with local Kafka Server

Pull Request - State: closed - Opened by debasishg over 6 years ago - 1 comment

#22 - The proc example application now runs with local Kafka Server

Pull Request - State: closed - Opened by debasishg over 6 years ago - 1 comment

#21 - Fix unit test in kafka-stream-s library

Pull Request - State: closed - Opened by debasishg over 6 years ago

#20 - Can run local Kafka server through config

Pull Request - State: closed - Opened by debasishg over 6 years ago

#20 - Can run local Kafka server through config

Pull Request - State: closed - Opened by debasishg over 6 years ago

#19 - Exploit sam interop

Pull Request - State: closed - Opened by maasg over 6 years ago - 6 comments

#18 - Added notes about cross version building.

Pull Request - State: closed - Opened by deanwampler over 6 years ago - 1 comment

#17 - Review/Minor chages

Pull Request - State: closed - Opened by maasg over 6 years ago

#16 - Tonnes of documentation added

Pull Request - State: closed - Opened by debasishg over 6 years ago - 1 comment

#16 - Tonnes of documentation added

Pull Request - State: closed - Opened by debasishg over 6 years ago - 1 comment

#15 - Refinements to documentation and updated SBT plugins.

Pull Request - State: closed - Opened by deanwampler over 6 years ago

#14 - Added another sample application based on KS procedure APIs

Pull Request - State: closed - Opened by debasishg over 6 years ago

GitHub / lightbend/kafka-streams-scala issues and pull requests