Skip to content

Pull requests: segmentio/kafka-go

New pull request New
Clear current search query, filters, and sorts
71 Open 515 Closed
71 Open 515 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

add records.Partition and records.Index
#859 opened Mar 7, 2022 by achille-roussel • Draft
1
Fixed #428 by making reader.read respect context closure enhancement
#429 opened Apr 14, 2020 by feldgendler Loading…
1
@achille-roussel
15
Support for re-authentication
#492 opened Aug 24, 2020 by GreenStage Loading…
@nlsun
5
Added method GetControllerConn() in conn.go and related test .
#495 opened Aug 29, 2020 by Mbr2k Loading…
@Pryz
3
feat: first draft of the reader group
#522 opened Sep 24, 2020 by fvosberg Loading…
@nlsun
2
Propagate Preferred read replica to FetchResponse
#568 opened Dec 2, 2020 by Pryz Loading…
@achille-roussel
StickyPartitioner implemented
#589 opened Jan 16, 2021 by alrz1999 Loading…
1
@nlsun
15
GSSAPI SASL mechanism based on gokrb5/v8
#598 opened Feb 2, 2021 by viasat-akozhevnikov Loading…
@achille-roussel
12
feat(client): add topic partition count helper
#631 opened Apr 12, 2021 by dominicbarnes • Draft
1
@achille-roussel
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
Skip messages from aborted transactions
#261 opened Apr 26, 2019 by VictorDenisov Loading…
@achille-roussel
13
Add kafka-go/records package
#855 opened Feb 23, 2022 by achille-roussel Loading…
15
WIP: TLS error enhancements
#867 opened Mar 18, 2022 by rhansen2 Loading…
@achille-roussel
2
Update CI to test kafka-go against kafka 2.8.1
#948 opened Jul 13, 2022 by code-haven Loading…
1
WriteMessageGroup function to skips the batching and send messages directly to the producer
#986 opened Sep 12, 2022 by yusufozturk Loading…
@nlsun
3
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
Add DescribeLogDirs to Client
#1000 opened Sep 28, 2022 by txdyzdy Loading…
@rhansen2
11
Update dialer.go
#1070 opened Feb 1, 2023 by dxasu Loading…
@achille-roussel
3
fix unlimit batchQueue
#1073 opened Feb 4, 2023 by jseparator Loading…
@rhansen2
Add Conn.WriteMulti function to produce to multiple topics/partitions
#1094 opened Mar 10, 2023 by stevevls Loading…
@rhansen2
2
Remove the BatchQueue type
#1117 opened Apr 17, 2023 by PleasingFungus Loading…
@rhansen2
10
docs: fix typos and comments
#1382 opened May 3, 2025 by gzipChrist Loading…
ProTip! Follow long discussions with comments:>50.