Jeferson David Ossa issues

Repositories
Issues
Comments

Results 1 issues of


                                            Jeferson David Ossa

Detecting Consumer Failures

I have a case with an unpredictable delay in the processing time of messages, following [Kafka consumer documentation](https://kafka.apache.org/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html) I modified [KafkaConsumerObservable.runLoop](https://github.com/monix/monix-kafka/blob/master/kafka-0.11.x/src/main/scala/monix/kafka/KafkaConsumerObservable.scala#L83) as follows: ```scala def runLoop(consumer: KafkaConsumer[K, V]): Task[Unit] =...