kafka-go

kafka-go copied to clipboard

AllowAutoTopicCreation does not exist in writer config, but only in the writer struct

1

AllowAutoTopicCreation to be introduced to writer config, and passed through to the writer itself. **Supporting documentation** ``` // AllowAutoTopicCreation notifies writer to create topic if missing. AllowAutoTopicCreation [bool](https://pkg.go.dev/builtin#bool) ```

yogeshg

yogeshg

Offset is going ahead and we are missing message with lag

7

We are using ReadMessage function with Consumer group, which works pretty good. but sometime one of the partition offset is getting set ahead of it commited message/s so those in...

NitinHsharma

What does QueueCapacity parameter mean. I read the explanation but I don't fully understand.

mertturkman

What is the difference between kafka.NewConsumerGroup and kafka.NewReader, and if there is no difference, which one is better to use in general?

ysk229

Allow null replicas in RequestPartition

1

The `replicas` slice was declared as an empty slice which precludes passing a nil slice in the case of wanting to cancel an ongoing assignment.

leizor

Hi kafka-go Team, I'm using your library for a project and have encountered a situation where frequent authorization retries are causing high load on our Kafka brokers. I've looked into...

mikhail-sukhodolov

**Describe the solution you would like** Could we have a method that combines Batch.Read() and Batch.ReadMessage() Where if there is enough space in msg.Value and msg.Key it will reuse those...

rouzier

How to remove topics from client?

1

Hi, it is possible to dynamically add topics with `AddConsumeTopics`, but how can we remove them? Thank you in advance.

StarpTech

Should retry when the error occurs.kafka.(*Client).Produce: fetch request error: topic partition has no leader

2

**Describe the bug** Kafka is encountering this error for some reason, but the client should support retries. I have configured the number of retries, but it is not working. My...

stonever