issues
search
twmb
/
franz-go
franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.7+. Producing, consuming, transacting, administrating, etc.
BSD 3-Clause "New" or "Revised" License
1.78k
stars
182
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Request Errors metric support
#830
asg0451
opened
1 week ago
0
Add Opts method for sr.Client
#829
andrewstucki
opened
1 week ago
0
Consuming from Kafka with some wait time in between fetches
#828
adriangomez24
opened
1 week ago
1
`*kgo.Record` pooling support
#827
ortuman
opened
1 week ago
0
Don't set nil config when seeding topics in kfake cluster
#826
colega
opened
2 weeks ago
1
get rid of record allocation in `kgo.recordToRecord`
#825
ortuman
closed
2 weeks ago
0
`kgo.Record` pooling support
#824
ortuman
closed
2 weeks ago
0
high number of allocations in `kgo.recordToRecord` function
#823
ortuman
opened
2 weeks ago
2
Apparently invalid "connection refused" errors on Redpanda Cloud connection
#822
genzgd
opened
2 weeks ago
1
Fix typo in Record.ProducerID doc comment.
#821
seizethedave
opened
2 weeks ago
0
kprom: Multiple clients
#820
lukasrynt
opened
2 weeks ago
0
Change error string for sr.ResponseError
#819
weeco
opened
2 weeks ago
1
strange issue with 1.17.0
#818
vtolstov
opened
3 weeks ago
2
Direct consumer doesn't implement KIP-392
#817
soundvibe
closed
3 weeks ago
3
Fetch retry with COORDINATOR_NOT_AVAILABLE error never recovers
#816
genzgd
opened
1 month ago
2
kprom: Support for multiple clients
#815
lukasrynt
opened
1 month ago
2
kadm: add `NewOffsetFromRecord` helper function
#814
noamcohen97
opened
1 month ago
0
Potential memory leak in kgo/broker.go
#813
sgtsquiggs
closed
1 month ago
2
Fix typo in kgo.Client.ResumeFetchTopics() docs
#812
mihaitodor
opened
1 month ago
0
Consumers stuck in endless rebalancing loop (consumer based off the goroutine-per-partition example)
#811
sgtsquiggs
opened
1 month ago
0
`GetConsumeTopics` returns all topics when consuming via regex, not just the topics that are being consumed
#810
twmb
opened
1 month ago
2
BrokerResponse too large
#809
sakib-malik-7417
closed
2 weeks ago
6
sr: add support for using bearer tokens in client
#808
weeco
closed
1 month ago
0
kgo.LiveProduceConnection option for low-latency settings
#807
helgeholm
opened
1 month ago
4
Remove unnecessary condition in if statements
#806
chakku000
closed
1 week ago
0
Bump epoch if the log_start_offset advanced and broker returned unknown_producer_id
#805
twmb
opened
1 month ago
0
Update GroupMetadataKey / GroupMetadataValue
#804
twmb
opened
1 month ago
0
fetching: export utilities for decompressing and parsing partition fetch responses
#803
dimitarvdimitrov
opened
1 month ago
2
Clarify bytes metrics description
#802
pracucci
closed
1 month ago
1
Question regarding manual commit example
#801
Iadgarov
closed
1 month ago
1
Cache metadata more
#800
twmb
opened
1 month ago
1
Decoding GroupMetadataValueMember fails
#799
weeco
closed
1 month ago
1
Connecting franz-go with a confluent kafka cloud cluster
#798
sashithaf16
closed
1 month ago
2
sr: fix body of cl.SetMode
#797
r-vasquez
closed
2 months ago
0
Want to delete the consumer group after processing records from kafka
#796
puneetjindal1997
closed
2 months ago
1
Imbalanced Partition Assignment to Consumers Per Topic
#795
mehranmeidani
closed
2 months ago
1
kgo: add TopicID to the FetchTopic type
#794
twmb
opened
2 months ago
1
CHANGELOG: update for 1.17.1
#793
twmb
closed
2 months ago
0
kgo: allow record ctx cancelation to propagate a bit more
#792
twmb
closed
2 months ago
0
How to delete offset when message got consumed?
#791
puneetjindal1997
closed
2 months ago
4
fetch using topic id
#790
arjunnair1997
opened
2 months ago
3
kgo: export the wrapped error from ErrGroupSession
#789
sbuliarca
opened
2 months ago
5
Is there a way to test kgo.Opts returned from wrapper function?
#788
sappusaketh
closed
2 months ago
1
kgo: fix deadlock in Produce when using MaxBufferedBytes
#787
twmb
closed
2 months ago
2
kgo sink: fix read/write race for recBatch.canFailFromLoadErrs
#786
twmb
closed
2 months ago
0
Data Race: concurrent access to recBatch.canFailFromLoadErrs during retry errors
#785
rodaine
closed
2 months ago
4
Question: Is it safe to poll after receiving ErrGroupSession on poll when a broker node restarts in the cluster?
#784
sbuliarca
closed
2 months ago
1
README: `kafka-go` also works with Confluent Platform
#783
hhromic
closed
2 months ago
0
Add Conduit to list of users
#782
hariso
closed
2 months ago
2
fix setting lz4 compression levels
#781
asg0451
closed
2 months ago
8
Next