confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Description =========== I create a kafka consumer group and use Assign method for consuming specific topic with specific partition. If this topic has 7 partition, I will create 7 consumer...
Description =========== ARM64 build using golang:1.20-alpine3.17 fails. AMD64 using confluent-kafka-go v2.1.0 build succeeds. ARM64 and AMD64 with v2.0.2 are also successful. ``` go mod tidy && go mod vendor docker...
Description =========== I have created a setup using https://developer.confluent.io/get-started/go. Created broker in local docker container. docker compose for kafka broker: `version: '3' services: broker: image: confluentinc/cp-kafka:7.5.0 container_name: broker ports: -...
Description =========== We're trying to upgrade to v2.0.2. Developing microservices so to debug with telepresence, we need to compile and debug on Windows 10. Our client compiles and runs fine...
Description =========== Hi @edenhill, I'm actually facing some issues regarding timeout with `confluent-kafka-go 1.5.2`. See below the logs: **Error 1** ``` %4|1614175442.389|SESSTMOUT|rdkafka#consumer-27| [thrd:main]: Consumer group session timed out (in join-state...
Description =========== I am experiencing a linking error when building a Go application with the confluent-kafka-go package on Windows 11, using MSYS2 GCC. The error occurs during the linking phase,...
Originally in response to this message, and better metrics internally. https://github.com/confluentinc/confluent-kafka-go/issues/425#issue-559017454 ### Background: Our internal applications measure producer latency, by consuming directly from the topic and producing a diff of...
Description =========== Hi. I'm building instrument for go SDKs and I'm looking for a way to monitor R.E.D metrics (Rate / Error / Duration) for Kafka producer and consumer. May...
Description =========== The `ResourceType` enum of the admin api is incomplete according to the documentation: [Authorization in Confluent Platform using ACLs | Confluent Documentation](https://docs.confluent.io/platform/current/kafka/authorization.html#resources ) The entries 'Transactional ID' (value...
Description =========== ``` delivery_chan := make(chan kafka.Event, 10000) err = p.Produce(&kafka.Message{ TopicPartition: kafka.TopicPartition{Topic: topic, Partition: kafka.PartitionAny}, Value: []byte(value)}, delivery_chan ) e :=
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client