{"repo":"Trendyol/kafka-konsumer","free":true,"listed":false,"github":"https://github.com/Trendyol/kafka-konsumer","clone":"git clone https://github.com/Trendyol/kafka-konsumer.git","description":"Easy implementation of kafka consumer with built-in exception manager (kafka-cronsumer)","language":"Go","stars":168,"topics":["exception-handling","grafana","kafka","kafkaconsumer","prometheus","kafkaprod"],"license":"MIT","category":"analytics","readme_excerpt":"Kafka Konsumer Description Kafka Konsumer provides an easy implementation of Kafka consumer with a built-in retry/exception manager (kafka-cronsumer). Migration Guide V2 Release Notes - Added ability for manipulating kafka message headers. - Added transactional retry feature. Set false if you want to use exception/retry strategy to only failed messages. - Enable manuel commit at both single and batch consuming modes. - Enabling consumer resume/pause functionality. Please refer to its example and how it works documentation. - Bumped kafka-cronsumer to the latest version: - Backoff strategy support (linear, exponential options) - Added message key for retried messages - Added x-error-message to see what was the error of the message during processing - Reduce memory allocation. - Increase TP on changing internal concurrency structure. How to migrate from v1 to v2? You can get latest version via go get github.com/Trendyol/kafka-konsumer/v2@latest - You need to change import path from github.com/Trendyol/kafka-konsumer to github.com/Trendyol/kafka-konsumer/v2 - You need to change your consume function with pointer signature. - We moved messageGroupDuration from batchConfiguration.messageGroupDuration to root level. Because this field is used single (non-batch) consumer too. Installation Examples You can find a number of ready-to-run examples at this directory. After running docker-compose up command, you can run any application you want. Simple Consumer func main() { consumerCfg :","default_branch":null,"files":null,"tree":[],"storefront":"/r/Trendyol","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/Trendyol/kafka-konsumer/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}