twmb/franz-go

Issues

• ProduceSync returning "context canceled" error when parent context hasn't been cancelled

  #756 opened 20 days ago by saholman
  3

• Use EOS sessions with BlockRebalanceOnPoll

  #754 opened 20 days ago by kahartma
  2

• Documentation request / question

  #768 opened 2 days ago by asg0451
  1

• Incorrect documentation regarding sarama partitioner compatibility SaramaCompatHasher

  #764 opened 13 days ago by asg0451
  4

• Retry fetched records on handle error

  #771 opened 4 days ago by dro-sh
  1

• Broker Throttling

  #770 opened 6 days ago by jdenquin
  0

• RequestTimeoutOverhead appears to override Context cancellation

  #769 opened 11 days ago by JFlath
  1

• Produce Latency Spikes Due To Race Condition When Brokers Are Scaled Down

  #746 opened a month ago by aratz-lasa
  6

• Feature request: expose metadata to the user

  #765 opened 13 days ago by asg0451
  2

• Question: Why does kgo.StopProducerOnDataLossDetected() exist?

  #763 opened 14 days ago by asg0451
  2

• Kip-848: Next Generation Consumer Group

  #685 opened 4 months ago by aratz-lasa
  5

• GroupTransactSession Close hangs, preventing restart

  #753 opened 22 days ago by iamnoah
  4

• Confluent: Unable to create a topic due to policy violation

  #751 opened 22 days ago by Amogh-Bharadwaj
  3

• Is there a way to limit consumer PollRecords buffered fetches by size?

  #757 opened 19 days ago by genzgd
  1

• Produce batch time metrics

  #704 opened 2 months ago by owenhaynes
  4

• Need to "re-assume the IAM role when re-authenticating" to avoid "Session too short" errors on MSK

  #731 opened 21 days ago by saholman
  6

• [Question] Checking client state before using it

  #750 opened 21 days ago by bentcoder
  1

• TXN: error beginning transaction: invalid attempt to begin a transaction while already in a transaction

  #748 opened 21 days ago by bentcoder
  3

• Clarify producer batch config, once again

  #749 opened 21 days ago by kirilldd2
  3

• How to fetch zero records without waiting

  #752 opened 21 days ago by muxmuse
  1

• Support force using ListOffsetsRequest to fetch offset

  #699 opened a month ago by Max-Cheng
  11

• Expected behavior when producing to non-existent partition

  #711 opened a month ago by alistairking
  6

• OnPartitionsAssigned called twice for the same partitions

  #705 opened a month ago by iimos
  6

• add ability to provide own member id

  #734 opened a month ago by vtolstov
  3

• topic creation configs

  #688 opened 4 months ago by yakirSalt
  3

• There is no option to set max.poll.interval.ms

  #708 opened a month ago by GRbit
  5

• Fetch returns duplicate records after Kafka (RedPanda) disconnect

  #713 opened 2 months ago by genzgd
  3

• v1.17 release status

  #698 opened a month ago by twmb
  0

• Clarification NoOffsetReset

  #692 opened a month ago by esiqveland
  3

• Can not flush when MaxBufferedRecords reached

  #726 opened a month ago by evanzhang87
  0

• Enrich "read from broker errored, killing connection" log message with the Kafka message type

  #719 opened a month ago by pracucci
  1

• Consumer group rebalancing bug when switching from eager to cooperative consumers

  #686 opened a month ago by hamdanjaveed
  8

• kgo.FetchMaxPartitionBytes: increasing this option causes high memory usage

  #701 opened a month ago by sbuliarca
  3

• Batch and retry uncommitted records with group consumer and kotel

  #684 opened 2 months ago by yakirSalt
  7

• record failed after being retried too many times

  #675 opened 3 months ago by droger88
  2

• Producer can not write to broker nr. 2

  #716 opened a month ago by ErlendFax
  9

• Question - Purging and adding topics results in redelivery of old messages despite last offset

  #727 opened a month ago by StarpTech
  2

• question about sync=>async=>sync messaging

  #733 opened a month ago by vtolstov
  1

• Transaction is not properly aborted

  #729 opened a month ago by dvachaiev
  1

• Connection problem

  #728 opened a month ago by conrepcr
  1

• PollFetches take long time for the first fetch

  #732 opened a month ago by secmask
  2

• Getting the max offset

  #717 opened 2 months ago by hugokitano
  0

• Expose compression method to caller for PollRecords/PollFetches

  #714 opened 2 months ago by genzgd
  2

• ListOffsetsAfterMilli returns unexpected results when called against kfake cluster

  #706 opened 2 months ago by narqo
  0

• Any way to assign only commited offsets on rebalance?

  #702 opened 3 months ago by topofstack
  2

• reverted offset commit in kafka

  #689 opened 3 months ago by arjunnair1997
  2

• Metadata Refresh Does't Update Topic IDs After Topic Recreation

  #676 opened 4 months ago by aratz-lasa
  3

• Inconsistent partitioning strategy

  #680 opened 4 months ago by akshatraika-moment
  6

• [CustomPartitioner] Help required

  #679 opened 4 months ago by sakib-malik-7417
  2

• Library doesn't fail if it cannot update metadata

  #678 opened 4 months ago by MarcinGinszt
  1