Search results

Stale consumers after JVM shutdown

Status: Open.

#1341 In fd4s/fs2-kafka;

·misja-alma openedon Aug 8, 2024

Cannot deserialize Array[Byte] fields via Avro with Schema Registry

Status: Open.

#1330 In fd4s/fs2-kafka;

·willneedham93 openedon Jun 10, 2024

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

Status: Open.

#1293 In fd4s/fs2-kafka;

·ppodlovics openedon Jan 25, 2024

KafkaConsumer closed prematurely on finite streams

Status: Open.

#1292 In fd4s/fs2-kafka;

·ppodlovics openedon Jan 18, 2024

retry CommitTimeoutException

Status: Open.

#1280 In fd4s/fs2-kafka;

·razvanz openedon Nov 21, 2023

Stuck partitions - question about the pause/resume logic

Status: Open.

#1230 In fd4s/fs2-kafka;

·simonpetty openedon Aug 10, 2023

Multiple consumers read from the same partition after rebalance

Status: Open.

#1200 In fd4s/fs2-kafka;

·squadgazzz openedon May 11, 2023

Using Codec[A] with KafkaStreams

Status: Open.

#1144 In fd4s/fs2-kafka;

·caenrique openedon Jan 26, 2023

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

Status: Open.

#1128 In fd4s/fs2-kafka;

·ex-ratt openedon Dec 20, 2022

withCreateConsumer and withCreateProducter methods have been removed

docsNew or improved documentationNew or improved documentation

Status: Open.

#1085 In fd4s/fs2-kafka;

·noelwelsh openedon Oct 21, 2022

Records are missing when second rebalance happens.

Status: Open.

#1051 In fd4s/fs2-kafka;

·MrKustra94 openedon Aug 9, 2022

Consider using type-specific native Kafka serdes

Status: Open.

#962 In fd4s/fs2-kafka;

·bplommer openedon Apr 26, 2022

 ·  

v4.0.0