kafka-go

kafka-go copied to clipboard

rhansen2

panic when client returns an error instead of protocol response

1

In continuation to https://github.com/segmentio/kafka-go/pull/925, we are seeing the same behavior in other APIs, such as ListGroups, DescribeGroups, etc. For example from the listgroups protocol: ```go func (r *Response) Merge(requests []protocol.Message,...

dmarkhas

Is there some way to get current lag of the current consumer group?

12

Is there some way to get current lag of the current consumer group?I want to get the lag of each partition under the consumption group.Our project relies heavily on this.Confluent...

jiangjinggit

kafka-go updates to support Tiered Storage (KIP-405)

2

There are upcoming changes to Kafka to include Tiered Storage. The [API changes can be found here](https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage). Would the API changes mentioned in the KIP require modifications on kafka-go? **Supporting...

snalvi

Deserialize Protobuf payload based on 4-byte Schema ID from Schema Registry

3

**Support for Protobuf with Confluent Schema Registry** If the Kafka event is serialized in Protobuf and a 4-byte integer schema_id is put in front of the Protobuf binary stream, can...

ericsun2

Support DescribeLogDirs

2

**Describe the solution you would like** Implement support on the admin client to allow to call DescribeLogDirs https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/admin/AdminClient.html#describeLogDirs-java.util.Collection- **Supporting documentation** https://docs.cloudera.com/runtime/7.2.10/kafka-managing/topics/kafka-manage-cli-logdir.html https://kafka.apache.org/25/javadoc/org/apache/kafka/clients/admin/Admin.html I am not aware of the project structure...

lplazas

Update CI to test kafka-go against kafka 2.8.1

1

code-haven

w.WriteMessages: context deadline exceeded on MSK IAM

4

**Describe the bug** I activated IAM authentication on a Kafka cluster 2.7.0 (AWS MSK). Reading topics worked like a charm. However when writing to a partition I suffered timeout errors...

ayoul3

Supporting kafka static membership

3

Static membership requires setting of group.instance.id, which requires JoinGroup API key version 5 and Heartbeat API Key version 3. [Documentation](https://kafka.apache.org/protocol.html#The_Messages_JoinGroup) Validation of new member.id is changed in later releases. When...

huszkacs

metric tag purpose

1

The ReaderStats struct here: https://github.com/segmentio/kafka-go/blob/da91759e946436612f6e31af58971162bf1d058d/reader.go#L568 is using `metric` tag. I am not able to see any code which parses the tag. Is the tag being used for any purpose?

haxxorsid