Sean Glover comments

Results 258 comments of


                                            Sean Glover

At least once guarantees of Producer.committableSink

Got it. Yes, I would expect the completion signal to be emitted by the `Slick.source` and the stream to shutdown when all elements have successfully traversed. Your stream may be...

Akka Stream die and stop consuming

Hi @politrons. This is a common issue with the basic Kafka consumer (and as a result, Alpakka Kafka). Since deserialization occurs within the KafkaConsumer itself an exception is thrown in...

Akka Stream die and stop consuming

Supervision to resume (i.e. skip a message) wouldn't help here because Kafka client serdes exceptions are fatal.

Consumer sporadically doesn't receive messages when client.id is set

That's very strange. Do you observe any issues in your logs? Try enabling DEBUG logging.

Out of order consumption from kafka topic

Hi @lawrenceong. Are you seeing messages be processed out of sequence or are you reprocessing some messages (i.e. duplicate messages?) Also, commit refreshing is disabled by default since it's been...

[Failure] At-Least-Once One To Conditional should support batching of offsets `withOffsetContext`

https://travis-ci.org/github/akka/alpakka-kafka/jobs/699377074#L495

[Failure] At-Least-Once One To Conditional should support batching of offsets `withOffsetContext`

https://travis-ci.org/github/akka/alpakka-kafka/jobs/705758567#L504

[Failure] At-Least-Once One To Conditional should support batching of offsets `withOffsetContext`

My first idea here would have been to enable idempotence on the producer that produces the grouped messages to `topic-2`, but if dupes were generated by this producer then I...

[Failure] At-Least-Once One To Conditional should support batching of offsets `withOffsetContext`

https://github.com/akka/alpakka-kafka/pull/1366/checks?check_run_id=2514640841#step:6:260

[Failure] TransactionsSpec: must complete with messages filtered out and transient failure causing an abort with restartable source

https://travis-ci.org/akka/alpakka-kafka/jobs/601873942#L455