segmentio/kafka-go

Issues

• ReadMessage ends up in a loop and does not come out when kafka broker gets deleted

  #1295 opened 10 days ago by kirannittur
  0

• MessageTooLargeError is not conforming to `errors.Is`

  #1293 opened 12 days ago by Tang8330
  0

• unsubscribing from individual topics - confluent library limitation or Kafka API limitation

  #1294 opened 11 days ago by ORESoftware
  0

• Duplicate consumption occurs when join a new consumer and CommitInterval is configured

  #1259 opened 4 months ago by dalianzhu
  2

• a lot of unexpected EOF error when reading from partition

  #1286 opened a month ago by acynothia
  2

• Kafka Reader unable to read events from kafka when using StartOffset: kafka.LastOffset and GroupID when groupID is new

  #1291 opened 19 days ago by SpaskeISO
  0

• Authenticating with MSK SASL/SCRAM

  #1290 opened 22 days ago by Tang8330
  1

• Offset is going ahead and we are missing message with lag

  #1276 opened 2 months ago by NitinHsharma
  3

• How to remove topics from client?

  #1289 opened 23 days ago by StarpTech
  1

• Go1.16 cannot run tests

  #1280 opened 23 days ago by loktarjugg
  2

• Should retry when the error occurs.kafka.(*Client).Produce: fetch request error: topic partition has no leader

  #1288 opened 24 days ago by stonever
  0

• AllowAutoTopicCreation does not exist in writer config, but only in the writer struct

  #1278 opened 2 months ago by yogeshg
  1

• Making the producer backoff algorithm configurable

  #1285 opened a month ago by JSarvesh
  0

• Do not panic on errors

  #1284 opened a month ago by vbmithr
  0

• Issue: Getting half partitions while Consumer Group Migration

  #1283 opened a month ago by shubhamsnehi
  0

• Feture request: logger with different levels

  #1281 opened a month ago by iSerganov
  1

• How do I specify partition when producing messages，I want to implement ordered messages

  #1277 opened 2 months ago by gopherhiro
  1

• getting frequent non-zero number of bytes remaining error during DescribeGroups

  #1212 opened 7 months ago by tarun-discovery
  3

• Asynchronous mode in kafka package not working

  #1258 opened 3 months ago by HosseinRouhi79
  0

• What is QueueCapacity param ?

  #1275 opened 3 months ago by mertturkman
  0

• What is the difference between kafka.NewConsumerGroup and kafka.NewReader,

  #1272 opened 3 months ago by ysk229
  0

• authorization retries

  #1268 opened 3 months ago by mikhail-sukhodolov
  0

• A new method for Batch called ReadIntoMessage

  #1267 opened 3 months ago by rouzier
  0

• Subscribe topic on demand

  #1266 opened 4 months ago by manang
  0

• Observability : Kafka Consumer/Producer metrics and tracing.

  #1265 opened 4 months ago by surenw-serenade
  0

• Incorrect documentation in the code ReaderConfig.RetentionTime

  #1244 opened 4 months ago by MKuchum
  1

• After increasing partition count, consumer group is not assigned to the new partitions.

  #1262 opened 4 months ago by Abdulsametileri
  1

• kafka.Conn.Broker() and kafka.Conn.Controller() return different Host value when there is one broker.

  #1217 opened 7 months ago by longyue0521
  1

• Make `(msg *Message) totalSize()` public

  #1254 opened 5 months ago by taguhoiya
  0

• WriteMessages can force metadata updates when occur NotLeaderForPartition error

  #1221 opened 7 months ago by zydovech
  1

• The default value of fetch.max.wait.ms

  #1246 opened 5 months ago by qinjin
  1

• WriteMessages return Leader Not Available ErrorCode

  #1208 opened 6 months ago by zydovech
  1

• How do producers obtain the partition and offset of message sending

  #1224 opened 7 months ago by guozhao-coder
  2

• `reader.Close()` stuck randomly

  #1248 opened 6 months ago by sumerc
  1

• suggestion: replace existing Log interface with log/slog

  #1245 opened 6 months ago by kevinburkesegment
  0

• How can I get the latest message in a topic?

  #1240 opened 6 months ago by cocoza4
  2

• How can I specify the producer serializer and consumer deserializer?

  #1243 opened 6 months ago by hedon954
  1

• Ability to describe Kafka topic

  #1242 opened 6 months ago by Tang8330
  4

• Kafka Compatibility for the Client versions

  #1229 opened 6 months ago by hariever
  2

• Need to upgrade to Kafka Client version 3.6.0

  #1223 opened 6 months ago by devd120698
  1

• docs: An example of using Writer to create a missing topic imports has an import error in README

  #1231 opened 6 months ago by VMois
  1

• Can I use select to readmessage?

  #1220 opened 7 months ago by PengYang3
  1

• How to set kafka clientId when using high level writer API

  #1219 opened 7 months ago by lancedang
  0

• FetchMessage returns io.EOF when reader not closed

  #1222 opened 7 months ago by zydovech
  0

• Reader.ReadMessage(ctx) stalls 4-5 seconds, till it gets data back from producer

  #1213 opened 7 months ago by tahamazari
  1

• What does `-1 indicates unset` means in code comment

  #1214 opened 7 months ago by KillianG
  0

• Consumer group leaveGroup fail when group leader down

  #1215 opened 7 months ago by zydovech
  1

• Reader doesn't fetch messages after new consumer group creation when StartOffset is set to FirstOffset

  #1211 opened 7 months ago by M0rdecay
  2

• Cannot reset topic config value with AlterConfigs

  #1206 opened 8 months ago by bgranvea
  0

• Round Robin Balancer not working as expected, always send message to the partition 0

  #1207 opened 8 months ago by slouma2000
  4