Enno Runne
Enno Runne
> I don't understand what the `mapAsync(settings.parallelism)(identity)` achieves. It makes the stream await the completion of the futures from the producer and pass the produced result downstream. The parallelism limits...
Wouldn't it be much better to allow setting the value to be returned from `kafkaTopicConnectParam`?
Ok, I finally looked a bit into what you are trying to solve here. Your problem boils down which flags to pass on the command lines for zookeeper or non-zookeeper....
The Kafka Consumer actor pausing partitions indicates it has no demand for those. We suspect something could have been lost when actor state was updated during `WakeupException` handling. The release...
Related to #943
@feliperazeek We currently not working on this. Do you have any suggestions?
Thank you for sharing your observations. It is the same issue indeed.
This behaviour could even be achieved with an [`alsoTo`](https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/alsoTo.html) and two [`collectType`](https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/collectType.html) operators.
This looks like a problem in the Kafka client. You could try overriding the Kafka client Alpakka uses to Kafka 2.3. Please report back if that does help.
This issue is still open. We have not gotten enough information of what might be causing this problem. What Kafka version is your broker on?