Pablo Picouto García

Any update about this bug? Which is the best pattern right now to tackle this issue?

@johanandren How about back off strategy. https://doc.akka.io/docs/akka-stream-kafka/current/errorhandling.html#restarting-the-stream-with-a-backoff-stage or create the KafkaConusumerActor by myself and the subscribe in the pipeline to the topic as they do here https://github.com/kciesielski/reactive-kafka/blob/7dd29719a5d1c6eb70584e67bf9f4dbd7b6d2b39/docs/src/test/scala/sample/scaladsl/ConsumerExample.scala#L328 Then maybe the...

same issue here, I need those privileges

@ennru Hi enru, thanks for the response and link. We have coverage the problem of the de/serialization time ago using byteArray and then do it the encode/decode in a map...

Yes, so I can asume with your answer then that there’s no mechanism to make the supervisor strategy know when the consumer cannot talk with Kafka broker. I’m wondering if...

Well I hope they will listen to you 😄. But I think remove the max wake up time was not necessary a great move. In some scenarios maybe some people...

Hi David, I’m referring to FTP connector. Debulk means I receive file A.xml and I break down in a list of SourceRecords. we need transactionallity, if we cannot send all...

@ennru any idea when version 1.0 will be production ready?. I see that for now is just RC version.

Hi for the answer. Basically I have the problem that Finagle by default use an ExecutionContext with same number of threads as cores I have in my machine. And with...

Hi @hamdiallam This code that I posted was extracted from one filter that is trying to do that. The change you suggest it does not work and I think is...