Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / Trendyol/kafka-konsumer issues and pull requests

#145 - feat: add producer interceptor interface

Pull Request - State: closed - Opened by ademekici 12 days ago

#144 - Feature/producer interceptor

Pull Request - State: closed - Opened by ademekici 12 days ago

#143 - Feature/producer interceptor

Pull Request - State: closed - Opened by ademekici 12 days ago

#142 - feat: bump kafka-cronsumer v1.5.4

Pull Request - State: closed - Opened by ugurcanerdogan 29 days ago
Labels: dependencies

#141 - feat: write json and string methods for producer and consumer configs…

Pull Request - State: closed - Opened by oktaykcr about 1 month ago

#140 - feat: print human readable format to the config

Issue - State: closed - Opened by Abdulsametileri about 2 months ago - 1 comment

#139 - feat: wrap kafka client with sync once for support singleton

Pull Request - State: closed - Opened by Abdulsametileri about 2 months ago

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

Issue - State: open - Opened by osemrt 2 months ago - 1 comment

#134 - feat: provide message group limit default

Pull Request - State: closed - Opened by Abdulsametileri 3 months ago

#133 - chore: bump: bump goreleaser/goreleaser-action from 5 to 6

Pull Request - State: open - Opened by dependabot[bot] 4 months ago
Labels: dependencies, github_actions

#132 - feat: expose error metric when fetching message

Pull Request - State: closed - Opened by Abdulsametileri 4 months ago

#131 - feat: added topic exists check (#59)

Pull Request - State: closed - Opened by Abdulsametileri 4 months ago - 2 comments

#129 - feat: add batch byte size limit configuration

Pull Request - State: closed - Opened by mhmtszr 5 months ago - 1 comment

#128 - chore: bump: bump golangci/golangci-lint-action from 3 to 6

Pull Request - State: open - Opened by dependabot[bot] 5 months ago
Labels: dependencies, github_actions

#127 - chore: bump: bump golangci/golangci-lint-action from 3 to 5

Pull Request - State: closed - Opened by dependabot[bot] 5 months ago - 1 comment
Labels: dependencies, github_actions

#126 - feat: run integration tests in parallel

Pull Request - State: closed - Opened by ademekici 6 months ago - 1 comment

#125 - feat: could we decrease integration test minutes?

Issue - State: closed - Opened by ademekici 6 months ago - 1 comment

#124 - feat: make Pause and Resume methods idempotent

Pull Request - State: closed - Opened by Abdulsametileri 6 months ago - 1 comment

#123 - feat: enable balancer support to the retry configuration

Pull Request - State: closed - Opened by dilaragorum 6 months ago - 1 comment

#122 - fix: Transactional Retry false x-error-message bug

Pull Request - State: closed - Opened by Abdulsametileri 6 months ago - 2 comments

#121 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.52.1 to 2.52.4

Pull Request - State: closed - Opened by dependabot[bot] 6 months ago - 2 comments
Labels: dependencies, go

#120 - feat: add Balancer support to the RetryEnabled config

Issue - State: closed - Opened by Abdulsametileri 6 months ago - 3 comments

#119 - fix: Transactional Retry false x-error-message bug

Pull Request - State: closed - Opened by dilaragorum 6 months ago - 2 comments

#118 - Feature/kafka header filter

Pull Request - State: closed - Opened by dilaragorum 6 months ago

#117 - feat: add interceptor before produce etc.

Issue - State: closed - Opened by Abdulsametileri 6 months ago - 1 comment

#116 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.52.1 to 2.52.3

Pull Request - State: closed - Opened by dependabot[bot] 6 months ago - 2 comments
Labels: dependencies, go

#115 - Transactional Retry false causes x-error-message bug

Issue - State: closed - Opened by Abdulsametileri 6 months ago - 1 comment
Labels: bug

#114 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.52.1 to 2.52.2

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 2 comments
Labels: dependencies, go

#113 - chore(deps): bump github.com/prometheus/client_golang from 1.16.0 to 1.19.0

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 1 comment
Labels: dependencies, go

#112 - feat: fix security vuln CVE-2024-25124

Pull Request - State: closed - Opened by emretanriverdi 7 months ago - 1 comment

#111 - feat: added topic exists check (#59)

Pull Request - State: closed - Opened by keremcankabadayi 7 months ago - 2 comments

#110 - chore(deps): bump go.opentelemetry.io/otel from 1.19.0 to 1.24.0

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 2 comments
Labels: dependencies, go

#109 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.19.0 to 1.24.0

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 1 comment
Labels: dependencies, go

#108 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.50.0 to 2.52.1

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 2 comments
Labels: dependencies, go

#107 - chore(deps): bump go.uber.org/zap from 1.24.0 to 1.27.0

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 1 comment
Labels: dependencies, go

#106 - feat: add metric prefix config and expose metricCollectors

Pull Request - State: closed - Opened by Abdulsametileri 8 months ago - 1 comment

#105 - feat: add header filter feature

Pull Request - State: closed - Opened by dilaragorum 8 months ago - 1 comment

#104 - feat: add skip message by header filter function for cronsumer

Pull Request - State: closed - Opened by emrekosen 8 months ago - 1 comment

#103 - chore(deps): bump github.com/Trendyol/kafka-cronsumer from 1.4.6 to 1.4.7

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 1 comment
Labels: dependencies, go

#102 - chore: bump: bump golangci/golangci-lint-action from 3 to 4

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 2 comments
Labels: dependencies, github_actions

#101 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.19.0 to 1.23.1

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 2 comments
Labels: dependencies, go

#100 - chore(deps): bump go.opentelemetry.io/otel from 1.19.0 to 1.23.1

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 2 comments
Labels: dependencies, go

#99 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.19.0 to 1.23.0

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 2 comments
Labels: dependencies, go

#98 - chore(deps): bump go.opentelemetry.io/otel from 1.19.0 to 1.23.0

Pull Request - State: closed - Opened by dependabot[bot] 8 months ago - 2 comments
Labels: dependencies, go

#97 - Create SECURITY.md

Pull Request - State: closed - Opened by ugurcanerdogan 8 months ago - 3 comments
Labels: github_actions

#96 - Enable kafka-cronsumer header filter feature on kafka-konsumer

Issue - State: closed - Opened by emreodabas 8 months ago
Labels: enhancement

#95 - Consume message when header has expected value

Issue - State: closed - Opened by emreodabas 8 months ago - 1 comment
Labels: enhancement

#94 - feat: security pipeline integration

Issue - State: closed - Opened by Abdulsametileri 8 months ago - 3 comments

#93 - feat: enable multiple topics for retryable configuration

Issue - State: open - Opened by Abdulsametileri 9 months ago
Labels: enhancement

#92 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.19.0 to 1.22.0

Pull Request - State: closed - Opened by dependabot[bot] 9 months ago - 2 comments
Labels: dependencies, go

#91 - chore(deps): bump go.opentelemetry.io/otel from 1.19.0 to 1.22.0

Pull Request - State: closed - Opened by dependabot[bot] 9 months ago - 2 comments
Labels: dependencies, go

#90 - Add the default value "MessageGroupDuration" to the README.md

Pull Request - State: closed - Opened by oktaykcr 9 months ago

#89 - feat: add functionality pause and resume for consumer

Pull Request - State: closed - Opened by Abdulsametileri 9 months ago - 1 comment

#88 - Avoid calling NewAPI for multiple times

Issue - State: closed - Opened by mhmtszr 9 months ago - 1 comment
Labels: enhancement

#87 - fix: multiple consumer sync pool issue

Pull Request - State: closed - Opened by mhmtszr 9 months ago - 1 comment

#86 - feat: adding metric prefix config when multiple prometheus metric reg…

Pull Request - State: closed - Opened by Abdulsametileri 9 months ago - 1 comment

#85 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.50.0 to 2.52.0

Pull Request - State: closed - Opened by dependabot[bot] 9 months ago - 2 comments
Labels: dependencies, go

#84 - chore(deps): bump github.com/prometheus/client_golang from 1.16.0 to 1.18.0

Pull Request - State: closed - Opened by dependabot[bot] 9 months ago - 2 comments
Labels: dependencies, go

#83 - feat: add preBatch feature

Pull Request - State: closed - Opened by Abdulsametileri 10 months ago - 1 comment

#82 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.46 to 0.4.47

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago - 2 comments
Labels: dependencies, go

#81 - chore: update test deps

Pull Request - State: closed - Opened by Abdulsametileri 10 months ago

#80 - feat: add error description to message header

Pull Request - State: closed - Opened by oguzyildirim 10 months ago - 2 comments

#79 - chore(deps): bump github.com/Trendyol/otel-kafka-konsumer from 0.0.5 to 0.0.6

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago - 2 comments
Labels: dependencies, go

#78 - chore: bump: bump actions/setup-go from 4 to 5

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago - 2 comments
Labels: dependencies, github_actions

#77 - feat: stop and start consumers

Issue - State: closed - Opened by mhmtszr 10 months ago - 4 comments
Labels: enhancement

#76 - feature: add manual kafka message commit integration

Pull Request - State: closed - Opened by mhmtszr 10 months ago - 1 comment

#75 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.43 to 0.4.46

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago - 2 comments
Labels: dependencies, go

#74 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.43 to 0.4.45

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 2 comments
Labels: dependencies, go

#73 - chore(deps): bump go.opentelemetry.io/otel/sdk from 1.19.0 to 1.21.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 2 comments
Labels: dependencies, go

#72 - chore(deps): bump go.opentelemetry.io/otel from 1.19.0 to 1.21.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, go

#71 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.19.0 to 1.21.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, go

#70 - chore: fix security vulnerabilities for fiber package

Pull Request - State: closed - Opened by ademekici 11 months ago - 1 comment

#69 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.48.0 to 2.51.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 2 comments
Labels: dependencies, go

#68 - implement exponential backoff for consumers

Pull Request - State: closed - Opened by halilkocaoz 11 months ago - 3 comments

#67 - chore(deps): bump go.opentelemetry.io/otel/trace from 1.19.0 to 1.20.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, go

#66 - chore(deps): bump go.opentelemetry.io/otel/sdk from 1.19.0 to 1.20.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 2 comments
Labels: dependencies, go

#65 - chore(deps): bump go.opentelemetry.io/otel from 1.19.0 to 1.20.0

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, go

#64 - feat: add transactional retry feature

Pull Request - State: closed - Opened by oguzyildirim 11 months ago - 1 comment

#63 - chore(deps): bump github.com/Trendyol/kafka-cronsumer from 1.3.4 to 1.4.4

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 1 comment
Labels: dependencies, go

#62 - feat: change consumeFn and batchConsumeFn as pointer signature

Pull Request - State: closed - Opened by Abdulsametileri 11 months ago - 2 comments

#60 - chore: Fix typo in Makefile

Pull Request - State: closed - Opened by mehmetumit 12 months ago - 1 comment

#59 - write error log when topic is not created

Issue - State: closed - Opened by keremcankabadayi 12 months ago - 3 comments
Labels: enhancement

#58 - chore(deps): bump github.com/gofiber/fiber/v2 from 2.48.0 to 2.50.0

Pull Request - State: closed - Opened by dependabot[bot] 12 months ago - 2 comments
Labels: dependencies, go

#57 - chore(deps): bump github.com/segmentio/kafka-go from 0.4.43 to 0.4.44

Pull Request - State: closed - Opened by dependabot[bot] 12 months ago - 2 comments
Labels: dependencies, go

#56 - draft: implement non transactional batch consuming

Pull Request - State: closed - Opened by oguzyildirim 12 months ago

#53 - chore(deps): bump go.opentelemetry.io/otel/exporters/jaeger from 1.16.0 to 1.17.0

Pull Request - State: closed - Opened by dependabot[bot] 12 months ago - 2 comments
Labels: dependencies, go

#52 - fix: duplicate produce in otel producer

Pull Request - State: closed - Opened by esdonmez 12 months ago - 1 comment

#51 - fix: Otel_producer produces multiple messages

Issue - State: closed - Opened by esdonmez 12 months ago - 1 comment
Labels: bug

#50 - feat: implement non transactional batch consuming

Pull Request - State: closed - Opened by oguzyildirim 12 months ago

#49 - feat: implement non transactional batch consuming

Pull Request - State: closed - Opened by oguzyildirim 12 months ago

#48 - docs: add deadletter topic example

Pull Request - State: closed - Opened by BurakG01 12 months ago - 1 comment

#47 - Add cronsumer example with deadletter topic

Issue - State: closed - Opened by esdonmez almost 1 year ago - 1 comment

#46 - chore(deps): bump github.com/prometheus/client_golang from 1.16.0 to 1.17.0

Pull Request - State: closed - Opened by dependabot[bot] about 1 year ago - 2 comments
Labels: dependencies, go