confluent-kafka-go

confluent-kafka-go copied to clipboard

Facing blocking api call and performance degradation for readMessage

1

Description =========== We are trying to use seek/readMessage combination in a loop. We see that most of the time the readMessage causes a blocking behaviour on internal c lib's C._rk_queue_poll...

jforjava1981

Dynamically consuming protobuf messages with dynamicpb

2

Description =========== As best I can tell, it is not possible to dynamically read protobuf messages with the protobuf deserializer if the schema is not known in advance by way...

james-johnston-thumbtack

Description =========== We have Go Confluent client to read a message from topic abc. During process of message, we are producing message to another topic in async mode and listening...

vjakka-intel

acked data loss when brokers are unstable

4

Description =========== We are running a kafka cluster having some disk performance issues which lead some of partition leaders to be stepped down from time to time. Our client application...

jyoon17

[AdminAPI] Kafka createTopics returns nil error even if it can't create topic.

1

Description =========== Hi, I am trying to create a kafkatopic with this config using AdminAPI createTopics function. ``` { "name": "user:created", "numberOfPartitions": 3, "replicationFactor" : 2 } ``` The topic...

Utkagr

Can't build on Windows 10, linking issue

6

Description =========== I'm trying to build on Windows with `go build ./...`. Get the following linking errors. Please help. ``` PS C:\sources\opensource\confluent-kafka-go> go build ./... # github.com/confluentinc/confluent-kafka-go/kafka/go_rdkafka_generr C:\Users\pavel\sdk\go1.19.1\pkg\tool\windows_amd64\link.exe: running gcc...

plkn

Subscribed topic not available even though it's already created

8

Description =========== Since we moved from confluent-kafka-go 1.9.2 to 2.3.0, we get this error: `"code": 3, "err": "Subscribed topic not available: XXX: Broker: Unknown topic or partition"` it didn't happen...

saartamir

return more clearly topic error message

4

topic error was catch in ErrInvalidArg but it can show more clearly

darrkz

[KIP-848] Run integration tests with both the "classic" and "consumer" consumer groups

1

emasab

[Knowledge gathering question] How does librdkafka creates and sends batches over the network to the broker?

2

Description =========== Hi. I have been using confluent-kafka-go for some time. But all this time I have been wondering about how librdkafka creates and sends batches over the network to...

Sam-sad-Sajid