Issues
- 2
unsubscribe w/o passing whole list
#2920 opened by ORESoftware - 1
Support batch offset fetch requests
#2827 opened by hyunseo0404 - 1
Sincerely ask, is this redundant?
#2923 opened by Trinoooo - 3
High CPU usage in `newBrokerProducer.func2`
#2907 opened by dzy176 - 1
Does sarama still guarantee message ordering?
#2860 opened by wenyihu6 - 2
`Net.ReadTimeout` is not a network-level property
#2820 opened by leonidboykov - 7
kafka: Failed to produce message to topic myRsp: write tcp [ip1]:[port1]->[ip2]:[port2]: write: broken pipe
#2900 opened by yitian108 - 1
Will handling response this way result in subsequent requests all being mishandled?
#2918 opened by AlexanderJLiu - 1
- 1
kafka server: The producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
#2915 opened by bentcoder - 7
Sync producer erroring for repeated transactions with the same transaction ID
#2859 opened by tomplarge - 1
- 2
- 3
PartitionOffsetManager.Close deadlock without autocommit
#2772 opened by maciej - 0
Incorrect rate5 metrics values
#2910 opened by gunli - 0
- 1
AsyncProducer.Close() waits for Flush.Frequency
#2805 opened by ssantichaivekin - 6
A topic with multiple partitions won't get dedicated consumer members in consumer group for each partition
#2899 opened by bentcoder - 5
Topic retention settings causes consumer to skip consuming new messages that arrived after deleted messages
#2898 opened by bentcoder - 3
not sure where to start with crash report
#2781 opened by R4wm - 1
Should share the max retries of metadata?
#2895 opened by yitian108 - 2
One bad issure
#2872 opened by GitHub-huyuan - 3
How do I specify partitions for production messages
#2844 opened by gopherhiro - 3
- 6
- 3
Possible Message Batching Bug?
#2797 opened by road-cycling - 3
Kafka: client has run out of available brokers
#2891 opened by logic-building - 1
sarama.CreateAclsRequest: Ignoring TextMarshaler & TextUnmarshaler for members
#2888 opened by Go-Giter - 5
Bug while adding new ACLs
#2885 opened by HaruChebrolu - 0
[Bug]: Current offset is higher than last offset
#2863 opened by vector-mj - 4
unaligned 64-bit atomic operation on i386
#2873 opened by gibmat - 4
Sarama Async Producer Encounters 'Out of Order' Error: what are the reasons?
#2803 opened by nevillus - 1
Sarama metrics leak in gracefull shutdown
#2861 opened by pandarun - 4
Consumers in a consumer group stuck for 4 days after ErrOffsetOutOfRange error
#2855 opened by shubham-dogra-s1 - 0
NewClusterAdmin check connection
#2852 opened by manang - 0
Why not just set Config.Metadata.Full to false?
#2849 opened by wy92 - 2
Error not being thrown when multiple consumer groups are created with the same group ID
#2842 opened by AhmedNSidd - 0
How to reset partition's offset of topic for consumer group by timestamp, use the timestamp instead of the specify offset
#2845 opened by jiawei666 - 3
Unable to use kerberos plaintext auth
#2780 opened by kamelusz - 2
Concern Regarding the rcrowley/go-metrics Dependency
#2832 opened by PaigeOmmen - 2
Error not handled
#2840 opened by ajeyprasad - 5
- 1
Too many goroutines in gopark state
#2839 opened by ajeyprasad - 2
Module name is github.com/IBM/sarama but expected github.com/Shopify/sarama
#2833 opened by alanmcdade - 0
What is the difference between `Consumer.Fetch.Max` and `Consumer.Fetch.Default`
#2831 opened by sappusaketh - 5
- 4
module declares its path as: github.com/IBM/sarama but was required as: github.com/Shopify/sarama, how could fix this ?
#2819 opened by gopherhiro - 0
Interceptor logger usage is invalid
#2801 opened by puellanivis - 1
[Question] What is the definition of GenerationID
#2775 opened by chientranthien - 9