Skip to content

Pull requests: segmentio/kafka-go

New pull request New
78 Open 542 Closed
78 Open 542 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

fix: reject negative record count in v2 record batch
#1442 opened Jul 10, 2026 by Socialpranker Loading…
1
fix: bound decoded array length to remaining frame bytes
#1441 opened Jul 10, 2026 by Socialpranker Loading…
1
fix: correct typos in comments
#1440 opened Jul 9, 2026 by maxtaran2010 Loading…
1
feat: refresh cluster metadata asynchronously on stale errors
#1437 opened Jun 11, 2026 by davidpst Loading…
1
fix: KIP-394
#1435 opened May 19, 2026 by piotrkowalczuk Loading…
feat: implement KIP-392 (consumer rack-aware fetching)
#1434 opened Apr 26, 2026 by GlebShipilov Loading…
2
fix: prevent panic from negative count on compacted topics
#1426 opened Feb 23, 2026 by veeceey Loading…
1
4
Fix consumer group stall when topic is auto-created after join
#1425 opened Feb 9, 2026 by n0RE5 Loading…
1
Add failing test for #1411
#1420 opened Jan 8, 2026 by greg0ire • Draft
feat(sasl): add OAUTHBEARER mechanism (RFC 7628)
#1418 opened Jan 7, 2026 by pilat Loading…
1
[AUTHR-376] Implement Oauthbearer mechanism
#1412 opened Nov 19, 2025 by twleescobar Loading…
@twleescobar
1
correct lengthRemain handling into message_read.readMessageV2
#1411 opened Nov 17, 2025 by Dmitriy-Kulagin Loading…
8
refactor: remove redundant port expose
#1406 opened Sep 6, 2025 by aljab012 Loading…
deadline for batch fetching
#1395 opened Jul 12, 2025 by max107 Loading…
fix: lower max msg byte in docker to allow us to test against kafka 4.0
#1392 opened Jun 25, 2025 by petedannemann Contributor • Draft
1
Add method to fetch messages in batch
#1390 opened Jun 8, 2025 by krsoninikhil Loading…
1
10
Fix Heartbeat Response V1+ field ordering
#1371 opened Mar 7, 2025 by jessekempf Contributor Loading…
Fix: #1314 partition watcher doesn't reacts on partition number changing
#1365 opened Jan 19, 2025 by arxon31 Loading…
12
Allow setting Set ConsumerGroupConfig.Timeout from ReaderConfig
#1363 opened Jan 14, 2025 by wwade Contributor Loading…
fix: A lot of unexpected EOF error when reading from partition
#1342 opened Oct 20, 2024 by jarvanstack Loading…
3
Report errors on writer close.
#1341 opened Oct 18, 2024 by gemyago Loading…
2
added-autoderive-batchSize--added-check-after-compression
#1340 opened Oct 17, 2024 by timmyb32r Loading…
6
Added SendPartialBatch Setting
#1339 opened Oct 17, 2024 by d1ngd0 Loading…
4
Added Azure Event Hubs Entra SASL Mechanism
#1338 opened Oct 10, 2024 by tnewman-at-gm Loading…
2
Expose Message.totalSize, Message.size, and Message.headerSize
#1337 opened Oct 2, 2024 by EvanMerlock Loading…
1
2
ProTip! Follow long discussions with comments:>50.