Skip to content

Issues: fd4s/fs2-kafka

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

46 Open 104 Closed
46 Open 104 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

Stale consumers after JVM shutdown
#1341 opened Aug 8, 2024 by misja-alma
3
Cannot deserialize Array[Byte] fields via Avro with Schema Registry
#1330 opened Jun 10, 2024 by onepintwig
1
Zipping finite KafkaConsumer-based streams doesn't behave as expected (first stream gets recycled after first 1000 elements)
#1293 opened Jan 25, 2024 by ppodlovics
1
KafkaConsumer closed prematurely on finite streams
#1292 opened Jan 18, 2024 by ppodlovics
retry CommitTimeoutException
#1280 opened Nov 21, 2023 by razvanz
Stuck partitions - question about the pause/resume logic
#1230 opened Aug 10, 2023 by simonpetty
23
Multiple consumers read from the same partition after rebalance
#1200 opened May 11, 2023 by squadgazzz
3
Using Codec[A] with KafkaStreams
#1144 opened Jan 26, 2023 by caenrique
Does KafkaConsumer.stopConsuming actually allow to process all in-flight messages?
#1128 opened Dec 20, 2022 by ex-ratt
7
withCreateConsumer and withCreateProducter methods have been removed docs New or improved documentation
#1085 opened Oct 21, 2022 by noelwelsh
13
Records are missing when second rebalance happens.
#1051 opened Aug 9, 2022 by MrKustra94
6
Consider using type-specific native Kafka serdes
#962 opened Apr 26, 2022 by bplommer v4.0.0
3
ConsumerRecord apply parameters missing
#956 opened Apr 22, 2022 by fd8s0
Timestamp type clarification in ConsumerRecord enhancement New feature or request
#955 opened Apr 22, 2022 by fd8s0 v4.0.0
2
Commits to retained partitions should continue during cooperative rebalance
#931 opened Mar 31, 2022 by bplommer
2
Rebalance of partitions with cooperative sticky assignor results in dead/unread partitions docs New or improved documentation
#914 opened Mar 22, 2022 by rney-lookout
3
Simplification of consumer internals
#903 opened Mar 14, 2022 by LMnet
3
3.0 release
#889 opened Mar 8, 2022 by bplommer
10
New stream method with the full rebalance information enhancement New feature or request
#876 opened Feb 21, 2022 by LMnet v4.0.0
3
Pin relevant dependencies for scala-steward
#830 opened Jan 2, 2022 by bplommer
Prefetched messages from revoked partition not dropped on Rebalance
#755 opened Nov 10, 2021 by jakobmerrild
3
Kafka consumer polling interval is multiplied by 2
#734 opened Oct 23, 2021 by Yevhensh
@aartigao
Improve resilience of ser/des using Vulcan amd Schema Registry
#663 opened Aug 20, 2021 by gordon-rennie
2
3
Poor performance compared to baseline
#635 opened Jun 24, 2021 by drewboardman
4
Rework or remove CommitRecovery enhancement New feature or request
#623 opened May 27, 2021 by LMnet v4.0.0
10
ProTip! Mix and match filters to narrow down what you’re looking for.