issues Search Results · repo:nomisRev/kotlin-kafka language:Kotlin
Filter by
26 results
(83 ms)26 results
innomisRev/kotlin-kafka (press backspace or delete to remove)The ReceiverSettings defaults to AutoOffsetReset.Earliest but default in Kafka is latest as per:
https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset
This should probably be aligned ...
kfh
- Opened 4 days ago
- #206
Hey @nomisRev,
would it be possible to make a new release with the latest fixes ? It s kind of a showstopper for using the 0.4 release
as of now.
- 3
- Opened on Jan 21
- #203
My deps:
implementation io.github.nomisrev:kotlin-kafka:0.3.0
implementation io.arrow-kt:suspendapp:0.4.0
implementation org.jetbrains.kotlinx:kotlinx-coroutines-core:1.9.0
Code:
import ...
Tolsi
- 1
- Opened on Dec 5, 2024
- #201
Hello!
First of all, thank you for this library!
I tried to update it from 0.3.1 to 0.4.0, but the consumer is now stuck during initialization.
After some troubleshooting, it seems that this is related ...
Morpheusse
- Opened on Jul 26, 2024
- #199
Here, when the channel successfully sends the records, the poll() function gets called and the current frame stuck in
the stack. Therefore, the stack will keep growing infinitely if the channel kept successfully ...
lsafer-meemer
- 2
- Opened on Jul 1, 2024
- #198
Sometimes settings are given as Properties. Having to read, decode and pass individual parameters to the any Settings
class is too much work.
My request is to add a function for each Settings class that ...
- 1
- Opened on Jul 1, 2024
- #197
Hello
The io.github.nomisRev.kafka.publisher.KafkaPublisher interface in this library exposes metrics() function to get
metrics from the underlying org.apache.kafka.clients.producer.KafkaProducer. Unfortunately, ...
gavvvr
- Opened on Jun 29, 2024
- #196
I use this library in my Ktor project, and runs the KafkaReceiver with IO dispatcher, and sets commitStrategy =
CommitStrategy.BySize(100), it throws java.util.ConcurrentModificationException. The full ...
winkey728
- Opened on May 25, 2024
- #195
The default CoroutineExceptionHandler in kotlin-kafka currently catches, logs, and then eats every exception that s
thrown in background coroutines. Unfortunately, that includes things like OutOfMemoryError ...
felixkrull-neuland
- 4
- Opened on Apr 19, 2024
- #192
When using 0.4.0, the Kafka receiver doesn t correctly connect to the Kafka cluster in certain situations. I ve seen
this in a test using a Kafka test container: the first test using a particular container ...
- 3
- Opened on Apr 9, 2024
- #191
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 IssuesProTip!
Press the /
key to activate the search input again and adjust your query.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 IssuesProTip!
Restrict your search to the title by using the in:title qualifier.