confluent-kafka-go

confluent-kafka-go copied to clipboard

Currently in a draft state because of the fact that librdkafka implementation isn't fully done, and so this should not be merged. Tested in conjunction with https://github.com/edenhill/librdkafka/tree/feature/list-and-alter-offsets (and depends on...

milindl

fix: initialise schema-registry tlsConf.RootCAs value (invalid memory address or nil pointer)

1

``` panic: runtime error: invalid memory address or nil pointer dereference [signal SIGSEGV: segmentation violation code=0x2 addr=0x20 pc=0x100fcd0e0] goroutine 1 [running]: crypto/x509.(*CertPool).addCertFunc(...) /opt/homebrew/Cellar/go/1.19.1/libexec/src/crypto/x509/cert_pool.go:189 crypto/x509.(*CertPool).AppendCertsFromPEM(0x0, {0x1400047a000?, 0x1400031f998?, 0x100dabf7c?}) /opt/homebrew/Cellar/go/1.19.1/libexec/src/crypto/x509/cert_pool.go:227 +0x260 github.com/confluentinc/confluent-kafka-go/schemaregistry.configureTLS(0x1400046da01?,...

ju-popov

admin-client: Implement DeleteGroups

2

Fixes #826 Follow Up ---------- When the `DescribeGroup` apI is available in the Go client, the integration test can be made more concise, without us having to create the second...

vsantwana

The ID in a message is always `-1` when `UseSchemaID` in the `serde.Serializer` is set.

1

Description =========== From here: https://github.com/confluentinc/confluent-kafka-go/blob/561a26092b1678e2ddcddbff6b2720ee4e85aaf9/schemaregistry/serde/config.go#L20-L29 I expect that the behaviour of `UseSchemaID` is to tell a Serializer to use that ID regardless what's on a Schema Registry. When invoking `serde.Serialize()`(I'm...

falau

docs: correct consumer example code in README

4

Signed-off-by: Salar Nosrati-Ershad as discussed in [this issue](https://github.com/confluentinc/confluent-kafka-go/issues/806).

snosratiershad

Update docs for consumer rebalancing offset management

1

The use of `stored offset` for the consumer rebalancing doc is a bit misleading because people might interpret that as referring to the in memory store (which is used for...

vivek-ng

Implement callback for SASL PLAIN credentials

1

# Introduction This PR is the sibling of https://github.com/edenhill/librdkafka/pull/3955 which adds a feature to librdkafka that allows the specification of a callback to obtain the SASL PLAIN credentials. The Golang...

josvisser66

[consumer] Propagate errors for Pause/Resume APIs

1

This propagates the individual errors for each TopicPartition that is being Paused/Resumed, into the input slice itself. An non-nil cumulative error is returned in case one or more of the...

milindl

Description =========== Assign partition consumption scenario, always start from offset 0 when restart the client. The test code is as follows: when Not specifying a partition,that's fine,I'm so confused.Somebody help?...

heketong

Description =========== Confluent-kafka-go v1.9.2 I am running a grpc server in go language. The APIs are defined using protobuf. Clients send data in a generic API where input object is...

Shukla-Ankur