confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Description =========== My service consumes messages from one topic. While the consumer is idle and blocked waiting for messages I see a continuous and linear increase in the POD memory....
code: package main import ( "fmt" "gopkg.in/confluentinc/confluent-kafka-go.v1/kafka" ) func main() { c, err := kafka.NewConsumer(&kafka.ConfigMap{ "bootstrap.servers": "192.168.5.32:9082", "group.id": "myGroup", "auto.offset.reset": "earliest", }) if err != nil { panic(err) } err...
Description =========== The method `Deserialize()` of the specific Avro deserializer has the signature like this: https://github.com/confluentinc/confluent-kafka-go/blob/1092e015153c87b7d282f224b9d3da597eaf2637/schemaregistry/serde/avro/avro_specific.go#L106 Although this method is not documented(nor tested) well, I expect the first return should...
Description =========== When sending data to kafka using an async, idempotent producer, we often see delivery report channel receive errors only showing: ``` "Local: Fatal error" ``` Our delivery report...
Description =========== I'm working with `confluent-kafka-go v1.9.1` and `Kafka v3.2.0`. I want to adjust the offsets with following code just right after creating `kafka.Consumer` instance with confluent. I'm decreasing all...
Description =========== We use protecode to scan our base image and find after introducing the confluent-kafka-go package, it introduce the belowing security vulnerabiltiy(CVE-2022-2068,CVE-2022-1292,CVE-2022-2097)  Checklist ========= Please provide the following...
Description =========== the error "kafka send fail:Local: Queue full" occurs where i async produce msg. go-confluent-kafka 1.9.0 on mac. How to reproduce ================ send many message. i don't know how...
Description =========== I already use `kafka.AdminClient.DeleteTopics` I would like to use `kafka.AdminClient.DeleteGroups` the same way Looks like all the proper types are already in `rdkafka.h` for example: operation `RD_KAFKA_ADMIN_OP_DELETEGROUPS` and...
Description =========== We are building Go-based producer/consumer applications and installing them into alpine-based docker images. As we've begun trying to include monitoring, we've discovered that there's no obvious way to...
Description =========== I am trying to provide `value.subject.name.strategy` config while creating Kafka producer but getting invalid config error. Any workaround for it? Also, I am trying to create an implementation...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client