Issues
- 2
Consumer can be rebalanced if poll is not called before `max.poll.interval.ms`
#101 opened by allantl - 0
kafka 1.0 has support for time based offsets.
#75 opened by borissmidt - 7
- 1
- 1
KafkaConsumerConfig and KafkaProducerConfig apply helpers do not properly set properties
#287 opened by tfreiling - 0
Handle Scala 2.13 deprecations
#114 opened by Avasil - 4
KafkaConsumerObservable and its subclasses use KafkaConsumer (implementation) instead of Consumer (interface)
#244 opened by girishkolantra - 0
- 6
Web documentation 📖
#202 opened by paualarco - 3
- 0
ConsumerObservable doesn't propagate the cancellation
#186 opened by cakper - 5
Can I just provide a org.apache.kafka.common.serialization.Serializer instead of the library's one?
#90 opened by yeryomenkom - 0
- 9
How to detect KafkaProducerSink failures?
#128 opened by yeryomenkom - 1
- 1
Create benchmarking module
#116 opened by Avasil - 0
Change map + errorHandle to Task.redeem
#130 opened by Avasil - 3
[Question] How do you manually commit the offset after processing each record
#24 opened by atiqsayyed - 2
Monix 3.0 / Scala 2.13
#112 opened by aksharp - 1
- 3
- 1
KafkaProducer send locks threads
#93 opened by voidconductor - 1
Add fetch.max.bytes to KafkaConsumerConfig
#88 opened by poslegm - 3
New release?
#81 opened by livelxw - 11
Confusion about the internals of ProducerSink
#36 opened by benjumanji - 1
Scalafmt config
#67 opened by poslegm - 1
Use Apache Kafka Producer and Consumer Java Map Constructor instead of Properties
#47 opened by sherwinschiu - 4
Commit after all connected multicasted observables are finished processing a record
#42 opened by yeenow123 - 0
Subscribing to topics regex support
#38 opened by lewapek - 8
[Question] Manual offset commit
#8 opened by 1015bit - 4
Kafka Streams API support
#32 opened by mihaisoloi - 5
Upgrade monix dependency
#15 opened by goral09 - 2
Detecting Consumer Failures
#20 opened by jedossa - 7
monix-kafka-11 not released
#25 opened by arlequin-nyc - 3
MAINTAINER WANTED!
#27 opened by alexandru - 2
- 1
Add max.poll.interval to KafkaConsumerConfig
#22 opened by leandrob13 - 0
kafka 0.9.0 client offset error
#18 opened by goral09 - 2
Add option to disable commit behaviour
#13 opened by Avasil - 0
Version for 0.11?
#10 opened by clayrat - 0
Callback-accepting Sink/Observable?
#9 opened by clayrat - 9
Version 0.14 not published for Scala 2.12
#7 opened by 1015bit - 0
Offsets issue
#6 opened - 2
Allow monix.kafka.Serializer and monix.kafka.Deserializer to provide instances manually
#4 opened by kdrakon - 0