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
#138 - feat: enhance Message Could Not Reader error by adding topic and cg info
Pull Request -
State: closed - Opened by Abdulsametileri about 2 months ago
#137 - feat: change skip message log level to debug and add Pretty for writing headers
Pull Request -
State: closed - Opened by Abdulsametileri 2 months ago
#136 - feat: disable instant retry for non transactional retry mode
Pull Request -
State: closed - Opened by Abdulsametileri 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
#130 - feature/use-retry-brokers-for-retry-producer use retry brokers when p…
Pull Request -
State: closed - Opened by ErenArslan 4 months ago
#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
#61 - Change consume and batch consume fn methods with pointer signature in order to support add remove header support
Issue -
State: closed - Opened by Abdulsametileri 11 months ago
- 1 comment
#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
#55 - Analyse concurrency, messageGroupLimit and messageGroupDuration configurations can be changed dynamically or not
Issue -
State: closed - Opened by Abdulsametileri 12 months ago
- 1 comment
Labels: enhancement
#54 - feat: add otel producer and consumer integration tests
Issue -
State: closed - Opened by Abdulsametileri 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