confluent-kafka-go

confluent-kafka-go copied to clipboard

emasab

Add Stats.Bytes()

1

Given that Go uses `[]byte` mostly to represent JSON data, it makes a lot of sense to add a `Stats.Bytes()` call returning a `[]byte` instead of a `string`. Perhaps it...

jdemeyer

Go Producer Much slower than Python Producer

9

Description =========== Producer Slowness in confluent-kafka-go We have 2 Kafka Producers working with given settings one in Python and one in Go, Go Kafka Producer need to change the `queue.buffering.max.ms`...

abhinavsolan

Description =========== I configured consumer with `allow.auto.create.topics` and consumed Kafka, but it doesn't work. Kafka did not crreate non-existed topics automatically and confluent-kafka-go returned error: `Broker: Unknown topic or partition:...

BruceDu521

Delivery report from events channel does not have timestamp and headers

4

Description =========== Delivery report of message from events channel, when using channel producer does not have timestamp or headers. This behavior is same for successfully delivered, as well as on...

jasimsulaiman

[Question] Receiving multiple times the same Consumer Groups

2

Description =========== I've tried this [example code](https://github.com/confluentinc/confluent-kafka-go/blob/master/examples/admin_list_consumer_groups/admin_list_consumer_groups.go) to list consumer groups of my 3 clusters and noticed that on one of them I get 1x (majority of cases) 2x and...

pawelcit

Memory leak while producing message?

5

Description =========== I'm trying to build API server that send to Kafka message queue when it receive request with HTTP Call. The servers are running on the Kubernetes. Whenever it...

devFallingstar

Description =========== The use-case here is we have a union schema registered on the topic that references all the sub-schemas. Now, it should be something like this: we make an...

VipulZopSmart

High memory usage when producing messages

2

Description =========== I run a process to write messages to redpanda for pressure test, the memory usage is very high with `kafka._Cfunc_GoBytes`. It's so weird. How to reproduce ================ Run...

intfish123

Build fails on mac M1 with Bazel

2

Description =========== I am trying to use the confluent-kafka-go library in my project. The build fails with the following error: ``` bazel build //simulation/services/simulationrunner --sandbox_debug INFO: Invocation ID: b75c6734-928a-46e6-b461-70b91e0bee44 INFO:...

zphoenixrises