kafka-konsumer

kafka-konsumer copied to clipboard

mhmtszr

Bumps [golangci/golangci-lint-action](https://github.com/golangci/golangci-lint-action) from 3 to 6. Release notes Sourced from golangci/golangci-lint-action's releases. v6.0.0 What's Changed This version removes annotations option (because it was useless), and removes the default output format...

dependabot[bot]

I will write more detail soon

Abdulsametileri

write error log when topic is not created

2

``` Reader: kafka.ReaderConfig{ Brokers: strings.Split(getConsumerServers(a.Kafka), ","), GroupID: consumerCfg.ConsumerGroup, GroupTopics: consumerCfg.Topics, MaxWait: 2 * time.Second, CommitInterval: time.Second, Logger: l, ErrorLogger: l, }, ``` I added logger and error logger. I would...

keremcankabadayi

feat: added topic exists check (#59)

1

keremcankabadayi

Currently, RetryConfiguration gets only topic but we can supports topics

Abdulsametileri

Abdulsametileri

We could create individual README files for each example. This approach will leverage the adaptation of new contributors and users. README files could include below items; - Description of Example...

emreodabas

this issue for you @oktaykcr bro

Abdulsametileri

bug: Doesn't try to connect with the next broker

1

Hi, I noticed an issue with brokers. A set of the Kafka broker list in the application configs is given to increase the availability. if the broker list contains invalid...

osemrt