yitian108

How consumer group support multiple consumers consume the same group?

1

##### Versions *Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.* | Sarama | Kafka | Go | |--------|-------|----| | 1.37.0 |2.5.0 |...

##### Versions *Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.* | Sarama | Kafka | Go | |--------|-------|----| | 1.37.0 | 2.5.0...

##### Versions *Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.* | Sarama | Kafka | Go | GoLand | |--------|-------|----|------| | 1.37...

How can the remaining messages in claim.Messages() be consumed when using manual commit in a consumer group?

2

As the code show in #1987, ```go func (h *handler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error { i := 0 for m := range claim.Messages() { msg := m.Value if err...

kafka: Failed to produce message to topic myRsp: write tcp [ip1]:[port1]->[ip2]:[port2]: write: broken pipe

8

##### Description Hi there, I encountered an old issue similar to #1565 and #2004 when I use AsyncProducer ##### Versions | Sarama | Kafka | Go | | ------ |...

Should share the max retries of metadata?

1

#### Description When reviewing the function tryRefreshMetadata() in client.go, I noticed a shared variable attemptsRemaining (initialized as Metadata.Retry.Max) within the subfunction retry(). Every call to the function retry() decreases the...

### Description When using docker update --memory-reservation to set a memory soft limit (memory.high in cgroup v2), the parameter is not propagated to the container’s cgroup file (memory.high), even though...