Skip to content

Pull requests: segmentio/kafka-go

New pull request New
Clear current search query, filters, and sorts
68 Open 523 Closed
68 Open 523 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

StickyPartitioner implemented
#589 opened Jan 16, 2021 by alrz1999 Loading…
1
@nlsun
15 👍 4
feat: sasl reauthentication
#1230 opened Nov 10, 2023 by ertanden Loading…
1
@petedannemann
10 👍 3
GSSAPI SASL mechanism based on gokrb5/v8
#598 opened Feb 2, 2021 by viasat-akozhevnikov Loading…
@achille-roussel
12 👍 2
Add DescribeLogDirs to Client
#1000 opened Sep 28, 2022 by txdyzdy Loading…
@rhansen2
11 👍 2
Expose Message.totalSize, Message.size, and Message.headerSize
#1337 opened Oct 2, 2024 by EvanMerlock Loading…
1
👍 2
Skip messages from aborted transactions
#261 opened Apr 26, 2019 by VictorDenisov Loading…
@achille-roussel
13 👍 1
WriteMessageGroup function to skips the batching and send messages directly to the producer
#986 opened Sep 12, 2022 by yusufozturk Loading…
@nlsun
3 👍 1
fix: avoid return io.UnexpectedEOF error while remain is zero
#1287 opened May 2, 2024 by acynothia Loading…
1
3 👍 1
feat: first draft of the reader group
#522 opened Sep 24, 2020 by fvosberg Loading…
@nlsun
2 👍 1
Add Conn.WriteMulti function to produce to multiple topics/partitions
#1094 opened Mar 10, 2023 by stevevls Loading…
@rhansen2
2 👍 1
Support for re-authentication
#492 opened Aug 24, 2020 by GreenStage Loading…
@nlsun
5 👍 1
Fixed #428 by making reader.read respect context closure enhancement
#429 opened Apr 14, 2020 by feldgendler Loading…
1
@achille-roussel
15
Added method GetControllerConn() in conn.go and related test .
#495 opened Aug 29, 2020 by Mbr2k Loading…
@Pryz
3
Propagate Preferred read replica to FetchResponse
#568 opened Dec 2, 2020 by Pryz Loading…
@achille-roussel
fix: lower max msg byte in docker to allow us to test against kafka 4.0
#1392 opened Jun 25, 2025 by petedannemann • Draft
1
Make fetchOffsets response parse conform to kafka protocol
#748 opened Sep 23, 2021 by maralla Loading…
@achille-roussel
2
Sketch of Transaction API
#755 opened Oct 6, 2021 by rhansen2 • Draft
@achille-roussel
5
Allow the resolver to override the port setting
#802 opened Nov 30, 2021 by themulle Loading…
@achille-roussel
16
add records.Partition and records.Index
#859 opened Mar 7, 2022 by achille-roussel • Draft
1
Update CI to test kafka-go against kafka 2.8.1
#948 opened Jul 13, 2022 by code-haven Loading…
1
Write the base offset of the record set
#988 opened Sep 14, 2022 by ehwoahthere Loading…
@achille-roussel
2
closest replica fetching
#993 opened Sep 20, 2022 by petedannemann • Draft
1
fix unlimit batchQueue
#1073 opened Feb 4, 2023 by jseparator Loading…
@rhansen2
Remove the BatchQueue type
#1117 opened Apr 17, 2023 by PleasingFungus Loading…
@rhansen2
10
Add kafka-go/records package
#855 opened Feb 23, 2022 by achille-roussel Loading…
15
ProTip! Updated in the last three days: updated:>2025-06-29.