Peter Poschmann issues

Repositories
Issues
Comments

Results 3 issues of


                                            Peter Poschmann

Does KafkaConsumer.stopConsuming actually allow to process all in-flight messages?

The ScalaDoc of `KafkaConsumer.stopConsuming` says that "All currently running streams will continue to run until all in-flight messages will be processed" and "streams will be completed when all fetched messages...

Cannot add field default value if it contains a collection of records

When manually creating a record codec, then it is possible to define default values for fields. This works most of the time, but it will not work if the value...

Interrupting a consumer's partition stream interrupts the outer assignment stream

I stumbled upon a strange issue that I don't understand. Maybe someone can enlighten me? I have a consumer and interrupt the inner partition streams after a while (it doesn't...