confluent-kafka-go
confluent-kafka-go copied to clipboard
confluentinc
Confluent's Apache Kafka Golang client
Description =========== I'm trying to build a binary for the Docker image, however I'm running into quite a gcc error when running `go build`. How to reproduce ================ `Dockerfile` ```...
Description =========== Deserializing a message that doesn't meet the expected Schema Registry format can cause a panic as a result of attempting to make a slice with a negative length....
Description =========== #421 added the option to consume logs from a channel instead of writing them to stderr. As of Go 1.21 though, there is a fairly usable structured logging...
Description =========== ``` $ kafkacat -V kafkacat - Apache Kafka producer and consumer tool https://github.com/edenhill/kafkacat Copyright (c) 2014-2020, Magnus Edenhill Version 1.7.0 (JSON, Avro, Transactions, librdkafka 1.5.0 builtin.features=gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer) ``` ```...
Description =========== I'm writing a wrapper to use this kafka client in my project. I noticed that in case of specifying the wrong broker address, the producer Flush() method blocks...
to show how it must behave
Description =========== The problem occurred as part of volume testing [goneli](https://github.com/obsidiandynamics/goneli) with aggressive injection of random faults, with a Kafka broker that has been (intentionally) subjected to very high load....
In the comments to create the API key and the config parameters required "confluent" is to be used instead of "ccloud"
Tiniest fix that will save time for someone. I'm a newbie in Kafka, so I was sure there was something wrong with my Kafka setup, while I was decoding the...
Metadata
Owner
Metadata
Confluent's Apache Kafka Golang client