Peter Podlovics issues

Repositories
Issues
Comments

Results 2 issues of


                                            Peter Podlovics

Zipping finite KafkaConsumer-based streams doesn't behave as expected (first stream gets recycled after first 1000 elements)

Hello, I've run into an issue with finite fs2-kafka streams and zipping. It seems that if I take more than 1000 elements from the default-configured streams and then zip them,...

KafkaConsumer closed prematurely on finite streams

Hello, I've run into an issue where my app is consuming a finite number of records from a topic, does some processing, then commits the offsets. The issue is if...