confluent-kafka-go

confluent-kafka-go copied to clipboard

This is the test branch for CI migration.

jliunyu

When I suscribe to a topic which doesn't exists, the topic is not being created

6

Description =========== I'm creating a consumer which subscribes to a topic which doesn't exist, I'm expecting for it to create it automatically but it doesn't, instead I'm getting the following...

martin-dos-santos

Can't get allow.auto.create.topics=true to work

7

Description =========== After upgrading to v1.6.1 (from v1.1) topics are no longer auto created when subscribing to a topic that does not exist since before. Previously, as part of test...

tobgu

Description =========== jenkins build is failing and giving this error How to reproduce ================ ``` FROM golang:1.17-alpine # These 3 steps helps to speedup builds when using docker cache #...

scarshad

Description =========== Can't compile Go binaries with confluent-kafka-go on macos since latest update. Tried linking with cyrus-sasl from nixpkgs (darwin) as well as brew, same result. How to reproduce ================...

cmars

Run scripts under kafka/bin via Go code.

7

Is there a way of running the Kafka-topics.sh command from apache Kafka/bin directory via go lang code?

Mayuresh-Gharat

allow.auto.create.topics": "false" for producer gives misleading warning

1

Description =========== While trying to workaround the auto-created topic when using `GetMetadata()` with the admin client, I found help in this issue: #726 The solution was to set the default...

samba2

Producer.Close() does not free underlying memory.

8

Description =========== long story short i was trying to overcome issues which the kafka client encounter, by closing old producers and creating new ones, when i ran my testing for...

denis-rusakov

Proposal: Deprecate the channel-based Consumer API

4

## Abstract Currently there are two distinct Consumer APIs: channel-based and function-based. Each implementation has a different set of problems. This very fact can be confusing for users and for...

agis

Client connection hang when K8s pod of broker killed

3

Description =========== The broker pod is killed when producing data, I find the client will hand when the broker's pod is the leader of accessing partition and some error log...

jaime0815