inviqa/kafka-consumer-go issues and pull requests

#52 - fix kafka version in config

Pull Request - State: closed - Opened by revdaalex about 1 year ago

#51 - add next time retry in message

Pull Request - State: closed - Opened by revdaalex about 1 year ago

#50 - Update changelog for release v0.6.0

Pull Request - State: closed - Opened by hgajjar about 2 years ago

#49 - handling more than 1 retries

Pull Request - State: closed - Opened by bertalan-kis about 2 years ago

#48 - Update samara ErrOutOfBrokers check to cope with wrapping

Pull Request - State: closed - Opened by andytson-inviqa about 2 years ago

#47 - message headers and key get discarded for retry messages

Issue - State: open - Opened by andytson-inviqa about 2 years ago

#46 - Add support for Go 1.19

Pull Request - State: open - Opened by jbarton123 over 2 years ago - 1 comment

#45 - Update containerd dependency

Pull Request - State: open - Opened by jbarton123 over 2 years ago

#44 - Add SetDBDriver method

Pull Request - State: open - Opened by dantleech over 2 years ago - 1 comment

#43 - DSN in config is hardcoded to use Postgres

Issue - State: open - Opened by jbarton123 over 2 years ago
Labels: bug, good first issue

#42 - Support specifying the driver

Pull Request - State: closed - Opened by dantleech over 2 years ago - 1 comment

#41 - Remove test.NewConfig() helper

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago

#40 - Increase max connection attempts to 20

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago

#39 - Un-export collection interface methods

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: skip-changelog

#38 - Add dead-lettered prometheus gauge

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: enhancement

#37 - Memoize the DB connection pool as part of the config

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: enhancement

#36 - Update the documentation to remove references to env vars

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: documentation, skip-changelog

#35 - Use builder exclusively for configuration creation

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: enhancement

#34 - Pass session context to topic handlers

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: enhancement

#33 - Remove env vars used for configuration and inject as part of NewConfig()

Issue - State: closed - Opened by jameshalsall almost 3 years ago
Labels: enhancement

#32 - Encapsulate logic for determining handler for topic key

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: enhancement

#31 - Reduce flakiness of integration tests

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: bug, skip-changelog

#30 - Use a unique migrations table name

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: bug

#29 - Change last_error to text type to allow full error message

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: bug

#28 - Properly encode user/pass in DSN

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: bug

#27 - Log the error from DB ping check properly

Pull Request - State: closed - Opened by jameshalsall almost 3 years ago
Labels: bug

#26 - Return error when Kafka cluster never becomes available in time

Pull Request - State: closed - Opened by jameshalsall about 3 years ago
Labels: bug

#25 - Wait longer between connection attempts to Kafka

Pull Request - State: closed - Opened by jameshalsall about 3 years ago

#24 - Switch kafka/zookeeper images to bitnami variants

Pull Request - State: closed - Opened by jameshalsall about 3 years ago
Labels: skip-changelog

#23 - Ensure database is migrated when Start() is called

Pull Request - State: closed - Opened by jameshalsall about 3 years ago
Labels: bug

#22 - Upgrade two modules with security vulnerabilities

Pull Request - State: closed - Opened by jameshalsall about 3 years ago
Labels: security

#21 - Add CodeQL to github actions flow

Pull Request - State: closed - Opened by jameshalsall about 3 years ago
Labels: enhancement

#20 - Reduce number of goroutines and consumers for DB kafka collection

Pull Request - State: closed - Opened by jameshalsall over 3 years ago

#19 - Add test case for fail/succeed DB retry scenario

Pull Request - State: closed - Opened by jameshalsall over 3 years ago

#18 - Add maintenance job to the DB consumer collection

Pull Request - State: closed - Opened by jameshalsall over 3 years ago

#17 - Upgrade module dependencies

Pull Request - State: closed - Opened by jameshalsall over 3 years ago

#16 - Add support for DB retry queues as alternative to Kafka topics

Pull Request - State: closed - Opened by jameshalsall over 3 years ago - 1 comment

#15 - Switch changelog generator docker image

Pull Request - State: closed - Opened by kierenevans over 3 years ago - 1 comment

#14 - Reuse timer and stop correctly to prevent memory leak

Pull Request - State: closed - Opened by jameshalsall over 3 years ago
Labels: bug

#13 - Provide ability to set context on mock sarama session

Pull Request - State: closed - Opened by jameshalsall over 3 years ago
Labels: enhancement

#12 - Improve testing DX

Pull Request - State: closed - Opened by jameshalsall over 3 years ago
Labels: enhancement

#11 - Remove github.com/alexflint/go-arg

Pull Request - State: closed - Opened by jameshalsall over 3 years ago

#10 - Update config API, provide ability for custom topic naming

Pull Request - State: closed - Opened by jameshalsall over 3 years ago
Labels: enhancement

#9 - Add integration tests

Pull Request - State: closed - Opened by hgajjar over 3 years ago

#8 - Prepare 0.1.0 release, add release process

Pull Request - State: closed - Opened by jameshalsall over 3 years ago
Labels: skip-changelog

#7 - Expand GitHub actions to cover linting and gosec

Pull Request - State: closed - Opened by jameshalsall over 3 years ago

#6 - Allow requests to be routed to handlers based on a descriminator

Issue - State: open - Opened by dantleech over 3 years ago - 1 comment

#5 - Add full integration test suite

Issue - State: closed - Opened by jameshalsall over 3 years ago
Labels: enhancement

#4 - Provide ability to use a DB storage mechanism for retry and deadletter messages

Issue - State: closed - Opened by jameshalsall over 3 years ago
Labels: enhancement

#3 - Improve DX

Pull Request - State: closed - Opened by hgajjar almost 4 years ago - 1 comment

#2 - Reduce the set up code for implementing services

Issue - State: closed - Opened by jameshalsall almost 4 years ago - 1 comment
Labels: enhancement

#1 - Add GitHub actions checks

Pull Request - State: closed - Opened by jameshalsall almost 4 years ago

GitHub / inviqa/kafka-consumer-go issues and pull requests