Skip to content

Issues: segmentio/kafka-go

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

131 Open 579 Closed
131 Open 579 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

How to remove topics from client? bug
#1289 opened May 9, 2024 by StarpTech
1
Should retry when the error occurs.kafka.(*Client).Produce: fetch request error: topic partition has no leader bug
#1288 opened May 9, 2024 by stonever
a lot of unexpected EOF error when reading from partition bug
#1286 opened Apr 30, 2024 by acynothia
1
Making the producer backoff algorithm configurable enhancement
#1285 opened Apr 30, 2024 by JSarvesh
Do not panic on errors enhancement
#1284 opened Apr 27, 2024 by vbmithr
Issue: Getting half partitions while Consumer Group Migration
#1283 opened Apr 24, 2024 by shubhamsnehi
Feture request: logger with different levels enhancement
#1281 opened Apr 23, 2024 by iSerganov
1
AllowAutoTopicCreation does not exist in writer config, but only in the writer struct enhancement
#1278 opened Apr 9, 2024 by yogeshg
1
How do I specify partition when producing messages，I want to implement ordered messages bug
#1277 opened Mar 30, 2024 by gopherhiro
1
Offset is going ahead and we are missing message with lag bug
#1276 opened Mar 20, 2024 by NitinHsharma
3
What is QueueCapacity param ?
#1275 opened Mar 14, 2024 by mertturkman
What is the difference between kafka.NewConsumerGroup and kafka.NewReader, enhancement
#1272 opened Mar 9, 2024 by ysk229
authorization retries enhancement
#1268 opened Mar 1, 2024 by mikhail-sukhodolov
A new method for Batch called ReadIntoMessage enhancement
#1267 opened Feb 21, 2024 by rouzier
Subscribe topic on demand enhancement
#1266 opened Feb 14, 2024 by manang
Observability : Kafka Consumer/Producer metrics and tracing. enhancement
#1265 opened Feb 11, 2024 by surenw-serenade
Duplicate consumption occurs when join a new consumer and CommitInterval is configured bug
#1259 opened Jan 25, 2024 by dalianzhu
1
Make (msg *Message) totalSize() public enhancement
#1254 opened Jan 9, 2024 by taguhoiya
reader.Close() stuck randomly bug
#1248 opened Dec 8, 2023 by sumerc
1
suggestion: replace existing Log interface with log/slog enhancement
#1245 opened Nov 29, 2023 by kevinburkesegment
How do producers obtain the partition and offset of message sending enhancement
#1224 opened Nov 8, 2023 by guozhao-coder
2
FetchMessage returns io.EOF when reader not closed
#1222 opened Nov 3, 2023 by zydovech
WriteMessages can force metadata updates when occur NotLeaderForPartition error
#1221 opened Nov 3, 2023 by zydovech
1
Can I use select to readmessage? enhancement
#1220 opened Nov 2, 2023 by PengYang3
@amortezaei
1
How to set kafka clientId when using high level writer API bug
#1219 opened Nov 2, 2023 by lancedang
@hhahn-tw
ProTip! Follow long discussions with comments:>50.