fd4s/fs2-kafka

Issues

• Stale consumers after JVM shutdown

  #1341 opened 6 months ago by misja-alma
  3

• Multiple consumers read from the same partition after rebalance

  #1200 opened 2 years ago by squadgazzz
  2

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

  #1330 opened 7 months ago by onepintwig
  1

• Performance regression Producer 3.5.0 vs 3.4.0

  #1321 opened 9 months ago by atnoya
  9

• Records are missing when second rebalance happens.

  #1051 opened 2 years ago by MrKustra94
  6

• Stuck partitions - question about the pause/resume logic

  #1230 opened a year ago by simonpetty
  20

• Any reason `RebalanceInProgressException` isn't considered in`CommitRecovery.Default`?

  #1213 opened 10 months ago by balajirrao
  1

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

  #1128 opened 2 years ago by ex-ratt
  7

• AdminApiClient deleteTopic doesn't wait for completion.

  #744 opened a year ago by paul-snively
  4

• Question around custom Partition assignments

  #1199 opened a year ago by bcarter97
  3

• Misleading error message in `NotSubscribedException`

  #981 opened a year ago by danielleontiev
  1

• Simplification of consumer internals

  #903 opened 3 years ago by LMnet
  3

• commitBatch, commitBatchOption methods missing

  #1010 opened a year ago by Matzz
  1

• One message from Consumer?

  #1056 opened a year ago by darkfrog26
  6

• Kafka consumer polling interval is multiplied by 2

  #734 opened 3 years ago by Yevhensh
  0

• Thread naming strategy

  #693 opened a year ago by TimWSpence
  2

• The certificates docs aren't published

  #789 opened a year ago by SystemFw
  0

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

  #1293 opened a year ago by ppodlovics
  1

• KafkaConsumer closed prematurely on finite streams

  #1292 opened a year ago by ppodlovics
  0

• retry CommitTimeoutException

  #1280 opened a year ago by razvanz
  0

• Feature request (possibly) : Dynamic metering on Streams

  #1270 opened a year ago by TobiasRoland
  2

• Consider using type-specific native Kafka serdes

  #962 opened 3 years ago by bplommer
  3

• New stream method with the full rebalance information

  #876 opened 3 years ago by LMnet
  3

• Timestamp type clarification in ConsumerRecord

  #955 opened 3 years ago by fd8s0
  2

• Sample graceful shutdown code doesn't work with Cats Effect 3

  #994 opened a year ago by fqshopify
  4

• upgrade 3.x to CE 3.5.1 / fs2 3.8.0

  #1234 opened a year ago by samspills
  5

• Migrate build to sbt-typelevel

  #991 opened a year ago by bplommer
  1

• Confluent platform incompatibility

  #1222 opened a year ago by fedefernandez
  3

• A NPE is thrown from AvroDeserializer if the value is empty

  #992 opened 3 years ago by channingwalton
  7

• CE 3.5.0 async cancelation semantics

  #1181 opened 2 years ago by Jasper-M
  3

• It would be nice to have a `.option` method on `RecordSerializer`

  #1143 opened 2 years ago by wunderk1nd-e
  2

• 3.0 release

  #889 opened 3 years ago by bplommer
  10

• Using Codec[A] with KafkaStreams

  #1144 opened 2 years ago by caenrique
  0

• TransactionalKafkaProducer don't commit offset with empty records

  #1099 opened 2 years ago by chernovsa
  2

• withCreateConsumer and withCreateProducter methods have been removed

  #1085 opened 2 years ago by noelwelsh
  13

• Is there a way to check if the producer is ready to produce?

  #1054 opened 2 years ago by sergio-margale
  0

• Commits to retained partitions should continue during cooperative rebalance

  #931 opened 3 years ago by bplommer
  2

• Kafka Queues?

  #1040 opened 2 years ago by darkfrog26
  2

• Producing with empty key leads to producing in the same partition

  #1039 opened 3 years ago by sergio-margale
  2

• Version v3.0.0-M8 downgrades Kafka client from 3.1.0 to 2.8.1

  #1024 opened 3 years ago by rodrigo-molina
  4

• Random cancellation of calls in KafkaAdminClient

  #986 opened 3 years ago by vshalts
  1

• Fix mima config

  #989 opened 3 years ago by bplommer
  0

• Revert behaviour change from #902

  #972 opened 3 years ago by bplommer
  0

• ConsumerRecord apply parameters missing

  #956 opened 3 years ago by fd8s0
  0

• Avro union type issue with Schema Registry

  #689 opened 3 years ago by calvinlfer
  3

• Rebalance of partitions with cooperative sticky assignor results in dead/unread partitions

  #914 opened 3 years ago by rney-lookout
  3

• Upgrade to Kafka client v2.8.1 to address timing attack issue

  #821 opened 3 years ago by marko-asplund
  3

• Pin relevant dependencies for scala-steward

  #830 opened 3 years ago by bplommer
  0

• Prefetched messages from revoked partition not dropped on Rebalance

  #755 opened 3 years ago by jakobmerrild
  3

• Improve resilience of ser/des using Vulcan amd Schema Registry

  #663 opened 3 years ago by gordon-rennie
  3