issues
search
IBM
/
sarama
Sarama is a Go library for Apache Kafka.
MIT License
11.44k
stars
1.75k
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Fix bugs related to Idempotency and Strict ordering when MaxOpenRequests=1
#2942
richardartoul
closed
2 months ago
1
Ensure ordering of offset commit requests
#2941
prestona
closed
1 month ago
4
Re-ordering of offset commit requests can cause committed offset to move "backwards".
#2940
prestona
closed
1 month ago
1
fix(producer): treat ErrKafkaStorageError as retriable
#2939
richardartoul
closed
1 month ago
2
Broken pipe and EOF
#2938
errrov
opened
2 months ago
1
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.12
#2936
dependabot[bot]
closed
2 months ago
1
Add handling a new error code - 91
#2935
dimonleksin
opened
2 months ago
0
chore(deps): bump golang.org/x/net from 0.24.0 to 0.27.0 in the golang-org-x group across 1 directory
#2934
dependabot[bot]
closed
1 month ago
2
feat: update go directive to 1.20
#2933
mauri870
closed
1 month ago
2
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.11
#2932
dependabot[bot]
closed
2 months ago
1
Docs with examples using tls/ssl by cert files creating a producer and consumer
#2931
nenodias
closed
3 months ago
1
Setting a too high value for Producer.Retry.Max can lead to excessive memory usage.
#2930
0xBB2B
opened
3 months ago
1
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.10
#2929
dependabot[bot]
closed
3 months ago
1
How can consumer group consume new partition without losing data using OffsetNewest config?
#2927
AlexanderJLiu
opened
3 months ago
1
chore(deps): bump github.com/klauspost/compress from 1.17.8 to 1.17.9
#2926
dependabot[bot]
closed
1 month ago
0
fix(client): refactor duplicated replica+partition logic
#2925
Trinoooo
opened
3 months ago
0
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.8
#2924
dependabot[bot]
closed
3 months ago
1
Sincerely ask, is this redundant?
#2923
Trinoooo
closed
3 months ago
1
Fix cpu spin loop when pending is closed while buf is not empty
#2922
AleksandrShibanov
opened
3 months ago
2
chore(deps): bump golang.org/x/net from 0.24.0 to 0.26.0 in the golang-org-x group across 1 directory
#2921
dependabot[bot]
closed
2 months ago
1
unsubscribe w/o passing whole list
#2920
ORESoftware
opened
4 months ago
3
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.7
#2919
dependabot[bot]
closed
3 months ago
1
Will handling response this way result in subsequent requests all being mishandled?
#2918
AlexanderJLiu
closed
4 months ago
1
kafka server: The producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
#2915
bentcoder
opened
4 months ago
3
feat: add metadata field to consumer message
#2914
fufuceng
opened
4 months ago
1
Error and data race using transaction example from the library
#2913
bentcoder
closed
1 week ago
3
Incorrect rate5 metrics values
#2910
gunli
opened
4 months ago
1
fix: declare assignor variable for examples & clean up log format
#2909
kumakichi
closed
3 months ago
0
chore(ci): bump ubi8/ubi-minimal from 8.9 to 8.10
#2908
dependabot[bot]
closed
1 month ago
0
High CPU usage in `newBrokerProducer.func2`
#2907
dzy176
opened
4 months ago
4
No throughput difference between sync and async producers
#2906
bentcoder
closed
1 week ago
2
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.6
#2904
dependabot[bot]
closed
4 months ago
1
Enabling idempotency still allows producing same message
#2902
bentcoder
closed
4 months ago
0
chore: broker
#2901
datager
closed
4 months ago
0
kafka: Failed to produce message to topic myRsp: write tcp [ip1]:[port1]->[ip2]:[port2]: write: broken pipe
#2900
yitian108
closed
4 days ago
8
A topic with multiple partitions won't get dedicated consumer members in consumer group for each partition
#2899
bentcoder
closed
4 months ago
6
Topic retention settings causes consumer to skip consuming new messages that arrived after deleted messages
#2898
bentcoder
closed
4 months ago
5
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.5
#2897
dependabot[bot]
closed
4 months ago
1
chore(ci): bump golangci/golangci-lint-action from 5.0.0 to 6.0.1
#2896
dependabot[bot]
closed
1 month ago
0
Should share the max retries of metadata?
#2895
yitian108
closed
1 month ago
2
chore(ci): bump ubi8/ubi-minimal from `f30dbf7` to `2fa47fa`
#2894
dependabot[bot]
closed
4 months ago
1
fix(doc): correct JVM's config name corresponding to MaxWaitTime
#2893
abhipranay
closed
4 months ago
2
fix: allow skipping per message size check
#2892
ae-govau
closed
3 weeks ago
3
Kafka: client has run out of available brokers
#2891
logic-building
closed
3 weeks ago
4
chore(deps): bump golang.org/x/net from 0.24.0 to 0.25.0 in the golang-org-x group
#2890
dependabot[bot]
closed
4 months ago
1
chore(ci): bump golangci/golangci-lint-action from 5.0.0 to 5.3.0
#2889
dependabot[bot]
closed
4 months ago
1
sarama.CreateAclsRequest: Ignoring TextMarshaler & TextUnmarshaler for members
#2888
Go-Giter
closed
1 month ago
2
chore(ci): bump github/codeql-action from 3.25.2 to 3.25.3
#2887
dependabot[bot]
closed
4 months ago
1
chore(ci): bump golangci/golangci-lint-action from 5.0.0 to 5.1.0
#2886
dependabot[bot]
closed
4 months ago
1
Bug while adding new ACLs
#2885
HaruChebrolu
closed
1 month ago
6
Previous
Next