karafka/waterdrop issues and pull requests

#559 - Update dependency factory_bot to v6.5.1

Pull Request - State: closed - Opened by renovate[bot] 7 days ago

#558 - stabilize spec

Pull Request - State: closed - Opened by mensfeld 10 days ago
Labels: internal

#557 - Verify all kafka logs

Pull Request - State: closed - Opened by mensfeld 16 days ago

#556 - Add post-execution kafka warnings checks

Pull Request - State: closed - Opened by mensfeld 16 days ago
Labels: internal

#555 - support producers tagging

Pull Request - State: closed - Opened by mensfeld 30 days ago
Labels: enhancement

#554 - Provide ability to tag producer instances

Issue - State: closed - Opened by mensfeld 30 days ago
Labels: enhancement

#553 - fix rubocop-rspec remarks

Pull Request - State: closed - Opened by mensfeld about 1 month ago
Labels: internal

#552 - v2.8.1

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

#551 - add missing spec

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

#550 - improve transactional locking

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

#549 - WaterDrop should prevent opening a transaction using a closed producer

Issue - State: closed - Opened by mensfeld about 1 month ago
Labels: bug, transactions

#548 - remove compose obsolete version

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

#547 - use ruby 3.4 as default

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

#546 - raise on transactional attempt when non-transactional

Pull Request - State: closed - Opened by mensfeld 2 months ago

#545 - Update confluentinc/cp-kafka Docker tag to v7.8.0

Pull Request - State: closed - Opened by renovate[bot] 2 months ago

#544 - Update confluentinc/cp-kafka Docker tag to v7.7.2

Pull Request - State: closed - Opened by renovate[bot] 2 months ago

#543 - Update dependency ostruct to v0.6.1

Pull Request - State: closed - Opened by renovate[bot] 3 months ago

#542 - Update dependency ruby to v3.4.1

Pull Request - State: closed - Opened by renovate[bot] 3 months ago

#541 - use templates similar to karafka

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

#540 - WaterDrop::Errors::FlushFailureError successful

Issue - State: closed - Opened by katpadi 3 months ago - 1 comment
Labels: question

#539 - Measure full roundtrip latency from the enqueue moment until final confirmation from brokers

Issue - State: open - Opened by mensfeld 4 months ago
Labels: enhancement

#538 - use ruby 3.4-preview2

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

#537 - Support connection pool mode

Issue - State: open - Opened by mensfeld 4 months ago
Labels: enhancement

#536 - improve spec stability

Pull Request - State: closed - Opened by mensfeld 5 months ago

#535 - update cert

Pull Request - State: closed - Opened by mensfeld 5 months ago

#534 - v2.8.0

Pull Request - State: closed - Opened by mensfeld 5 months ago

#533 - Update confluentinc/cp-kafka Docker tag to v7.7.1

Pull Request - State: closed - Opened by renovate[bot] 5 months ago

#532 - align async dispatch logger messages

Pull Request - State: closed - Opened by mensfeld 5 months ago

#531 - Require ruby 3.1

Pull Request - State: closed - Opened by mensfeld 5 months ago

#530 - replace mit with lgpl

Pull Request - State: closed - Opened by mensfeld 5 months ago

#529 - remove 3.0 from CI

Pull Request - State: closed - Opened by mensfeld 5 months ago

#528 - Update dependency factory_bot to v6.5.0

Pull Request - State: closed - Opened by renovate[bot] 5 months ago - 1 comment

#527 - NoMethodError: undefined method `init_transactions' if `transactional.id` is specified

Issue - State: closed - Opened by eugene-nikolaev 5 months ago - 4 comments
Labels: question

#526 - Update dependency ruby to v3.3.5

Pull Request - State: closed - Opened by renovate[bot] 5 months ago

#525 - normalize dispatch many sync dispatches results

Pull Request - State: closed - Opened by mensfeld 5 months ago

#524 - normalize dispatched for transactional

Pull Request - State: closed - Opened by mensfeld 6 months ago
Labels: enhancement, transactions

#523 - improve spec stability

Pull Request - State: closed - Opened by mensfeld 7 months ago

#522 - Improve transactional spec stability

Issue - State: closed - Opened by mensfeld 7 months ago
Labels: internal

#521 - Move variants to fiber local

Pull Request - State: closed - Opened by mensfeld 7 months ago
Labels: enhancement

#520 - Update confluentinc/cp-kafka Docker tag to v7.7.0

Pull Request - State: closed - Opened by renovate[bot] 7 months ago

#519 - Update confluentinc/cp-kafka Docker tag to v7.6.2

Pull Request - State: closed - Opened by renovate[bot] 7 months ago

#518 - Dispatched collection in the ProduceManyError contains DeliveryHandle and DeliveryReport

Issue - State: closed - Opened by ujasur 7 months ago - 8 comments
Labels: enhancement, in-progress

#517 - Update dependency ruby to v3.3.4

Pull Request - State: closed - Opened by renovate[bot] 7 months ago

#516 - Replace throw API with raise WaterDrop::AbortTransaction

Pull Request - State: closed - Opened by mensfeld 7 months ago
Labels: enhancement, transactions

#515 - v2.7.4

Pull Request - State: closed - Opened by mensfeld 7 months ago

#514 - fix early return dangling state

Pull Request - State: closed - Opened by mensfeld 7 months ago
Labels: bug, transactions

#513 - Replace the `throw(:abort)` API with direct `WaterDrop::AbortTransaction` error

Issue - State: closed - Opened by mensfeld 7 months ago - 1 comment
Labels: enhancement, transactions

#512 - Raise an exception when using return/break/next in a transactional code block similar to Rails 8

Issue - State: closed - Opened by mensfeld 7 months ago - 1 comment
Labels: transactions

#511 - Consumer consuming error: Local: Erroneous state (state) post break flow in transaction

Issue - State: closed - Opened by mensfeld 7 months ago
Labels: bug

#510 - limit ms logger resolution

Pull Request - State: closed - Opened by mensfeld 7 months ago
Labels: enhancement

#509 - bump-deps-2024-06-29

Pull Request - State: closed - Opened by nijikon 7 months ago
Labels: dependencies

#508 - require karafka-core 2.4.3

Pull Request - State: closed - Opened by mensfeld 8 months ago

#507 - karafka-core bump

Pull Request - State: closed - Opened by mensfeld 8 months ago

#506 - bump-deps-2024-06-17

Pull Request - State: closed - Opened by nijikon 8 months ago
Labels: dependencies

#505 - Update dependency ruby to v3.3.3

Pull Request - State: closed - Opened by renovate[bot] 8 months ago

#504 - v2.7.3

Pull Request - State: closed - Opened by mensfeld 8 months ago

#503 - Introduce `reload_on_transaction_fatal_error` to reload the librdkafka after transactional failures

Pull Request - State: closed - Opened by mensfeld 8 months ago
Labels: enhancement, transactions

#502 - Wait timeout bypassed on unreachable cluster

Issue - State: closed - Opened by Aerdayne 8 months ago - 8 comments
Labels: transactions

#501 - Transactional sync producer raises a 'Purged in queue' exception when producing messages via the same producer that previously failed to produce messages

Issue - State: closed - Opened by Aerdayne 8 months ago - 6 comments
Labels: question

#500 - small remarks to the listener improvements pr

Pull Request - State: closed - Opened by mensfeld 8 months ago

#499 - Add topic scope to report_metric

Pull Request - State: closed - Opened by YadhuPrakash 8 months ago - 1 comment
Labels: enhancement

#498 - Memory optimizations

Pull Request - State: closed - Opened by mensfeld 8 months ago

#497 - bump-deps-2024-06-03

Pull Request - State: closed - Opened by nijikon 8 months ago

#496 - add 3.4.0-preview1

Pull Request - State: closed - Opened by nijikon 8 months ago

#495 - Implementation to report topic level statistics

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

#494 - Update dependency ruby to v3.3.2

Pull Request - State: closed - Opened by renovate[bot] 8 months ago

#493 - ensure acks cannot be altered when idempotent

Pull Request - State: closed - Opened by mensfeld 8 months ago

#492 - add idempotent? flag

Pull Request - State: closed - Opened by mensfeld 8 months ago
Labels: enhancement

#491 - Check if variants can work with idempontents on and acks changes. If not, validate similar to transactional alterations to ack

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

#490 - Enhance AppSignal and DataDog instrumentation with transactional metrics (when used)

Issue - State: open - Opened by mensfeld 8 months ago
Labels: enhancement, transactions

#489 - Provide `#idempotent?` similar to `#transactional?`

Issue - State: closed - Opened by mensfeld 8 months ago

#488 - Alias `with` with `variant`

Pull Request - State: closed - Opened by mensfeld 9 months ago
Labels: enhancement

#487 - Provide alias to `#with` named `#variant`

Issue - State: closed - Opened by mensfeld 9 months ago
Labels: enhancement

#486 - v2.7.2

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

#485 - Add delegate requirement

Pull Request - State: closed - Opened by samsm 9 months ago - 9 comments
Labels: bug

#484 - v2.7.1

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

#483 - Provide context based producer variants

Pull Request - State: closed - Opened by mensfeld 9 months ago
Labels: enhancement

#482 - v2.7.0

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

#481 - Protect rdkafka thread from instrumentation crashes

Pull Request - State: closed - Opened by mensfeld 10 months ago - 3 comments
Labels: enhancement

#480 - bump-deps-2024-04-19

Pull Request - State: closed - Opened by nijikon 10 months ago
Labels: dependencies

#479 - Make message_count a distribution

Pull Request - State: closed - Opened by isturdy 10 months ago - 3 comments

#478 - update core dependency

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

#477 - fix dd instr spec

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

#476 - Treat the queue size as a gauge rather than a cumulative stat

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

#475 - fix double middleware and double checks

Pull Request - State: closed - Opened by mensfeld 10 months ago
Labels: bug

#474 - Middleware runs twice when using buffered produce

Issue - State: closed - Opened by darthryking 10 months ago
Labels: bug

#473 - Update confluentinc/cp-kafka Docker tag to v7.6.1

Pull Request - State: closed - Opened by renovate[bot] 10 months ago

#472 - v2.7.0.rc1

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

#471 - fix compose

Pull Request - State: closed - Opened by mensfeld 10 months ago
Labels: internal, dependencies

#470 - bump-deps-2024-03-31

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

#469 - v2.7.0.beta2

Pull Request - State: closed - Opened by mensfeld 11 months ago

#468 - provide transaction status method

Pull Request - State: closed - Opened by mensfeld 11 months ago
Labels: enhancement, transactions

#467 - Support custom oauth bearer

Pull Request - State: closed - Opened by mensfeld 11 months ago - 2 comments
Labels: enhancement

#466 - align defaults so they can work with transactional producer out of the box

Pull Request - State: closed - Opened by mensfeld 11 months ago
Labels: bug

#465 - Transactional producer config not aligned by default

Issue - State: closed - Opened by mensfeld 11 months ago
Labels: bug

#464 - upgrade warnings from rdkafka

Pull Request - State: closed - Opened by mensfeld 11 months ago

#463 - v2.7.0.alpha1

Pull Request - State: closed - Opened by mensfeld 11 months ago

#462 - remove ruby 2.7 support

Pull Request - State: closed - Opened by mensfeld 11 months ago

#461 - change defaults

Pull Request - State: closed - Opened by mensfeld 11 months ago

#460 - bump-deps-2024-03-07

Pull Request - State: closed - Opened by nijikon 11 months ago

GitHub / karafka/waterdrop issues and pull requests