Ecosyste.ms: Issues

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

GitHub / reactor/reactor-kafka issues and pull requests

#417 - Switch to `ubuntu-22.04` runner

Pull Request - State: open - Opened by violetagg 5 days ago
Labels: type/chores

#416 - Bump the development-dependencies group across 1 directory with 2 updates

Pull Request - State: open - Opened by dependabot[bot] 17 days ago
Labels: type/chores

#415 - Create dco.yml

Pull Request - State: closed - Opened by violetagg 23 days ago
Labels: type/chores

#414 - Maven Central release 1.3.23 does not show up

Issue - State: closed - Opened by stipx 29 days ago - 2 comments

#413 - Bump the development-dependencies group across 1 directory with 2 updates

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: type/chores

#412 - Bump the development-dependencies group with 2 updates

Pull Request - State: closed - Opened by dependabot[bot] about 2 months ago - 1 comment
Labels: type/chores

#411 - Resume Not working

Issue - State: open - Opened by earthspiligrim 2 months ago

#410 - NVM

Pull Request - State: closed - Opened by original-codematrix 3 months ago - 1 comment

#409 - Upgrade the kafka-clients library to 3.9.0

Issue - State: open - Opened by mxcross 3 months ago
Labels: type/enhancement

#408 - Bump the development-dependencies group across 1 directory with 5 updates

Pull Request - State: open - Opened by dependabot[bot] 3 months ago
Labels: type/chores

#407 - Micrometer 1.10.13 is the last OSS release for 1.10.x series

Pull Request - State: closed - Opened by violetagg 3 months ago
Labels: type/dependency-upgrade

#406 - Reactor Core 3.4.41 is the last OSS release for 3.4.x series

Pull Request - State: closed - Opened by violetagg 3 months ago
Labels: type/dependency-upgrade

#405 - Fix MockReceiverTest#consumerMethods failure with reactor-core 3.5

Pull Request - State: closed - Opened by chemicL 4 months ago
Labels: type/bug

#404 - Bump the development-dependencies group across 1 directory with 7 updates

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 1 comment
Labels: type/chores

#403 - Bump the development-dependencies group with 3 updates

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 1 comment
Labels: type/dependency-upgrade

#402 - Regroup Dependabot updates

Pull Request - State: closed - Opened by artembilan 4 months ago - 2 comments
Labels: type/chores

#401 - Bump reactorCore from 3.4.36-SNAPSHOT to 3.4.42-SNAPSHOT

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 2 comments
Labels: type/dependency-upgrade

#400 - Bump micrometer from 1.10.10 to 1.10.13

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 5 comments
Labels: type/dependency-upgrade

#399 - Bump the development-dependencies group with 4 updates

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago
Labels: type/chores

#398 - Bump org.apache.kafka:kafka-clients from 3.6.0 to 3.6.2

Pull Request - State: open - Opened by dependabot[bot] 4 months ago - 4 comments
Labels: type/dependency-upgrade

#397 - Bump the development-dependencies group with 5 updates

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 2 comments
Labels: type/dependency-upgrade

#396 - GH-395: Add Dependabot support to the project

Pull Request - State: closed - Opened by artembilan 4 months ago - 9 comments
Labels: type/chores

#395 - Enable dependabot

Issue - State: closed - Opened by violetagg 4 months ago
Labels: type/chores

#393 - Kafka interceptor with Micrometer Observation

Issue - State: open - Opened by Renboo 5 months ago
Labels: type/enhancement

#391 - Not able to build the project from source

Issue - State: open - Opened by imtavish04 7 months ago

#390 - Migrate reference documentation to Antora

Pull Request - State: open - Opened by pderop 9 months ago - 1 comment
Labels: type/documentation

#389 - reactor.kafka.receiver.internals.MockReceiverTest > consumerMethods FAILED

Issue - State: closed - Opened by chemicL 11 months ago - 1 comment
Labels: type/bug

#388 - Ignore temporarily MockReceiverTest#consumerMethods

Pull Request - State: closed - Opened by chemicL 11 months ago
Labels: type/chores

#388 - Ignore temporarily MockReceiverTest#consumerMethods

Pull Request - State: closed - Opened by chemicL 11 months ago
Labels: type/chores

#387 - Start producing 1.4 snapshots with 1.4.0-SNAPSHOT

Pull Request - State: closed - Opened by chemicL 11 months ago
Labels: type/chores

#386 - Consumption stopped with slow consumer

Issue - State: open - Opened by abialas 12 months ago - 2 comments
Labels: :question:need-triage

#385 - Application Pod Crashed: Kafka Producer Exhausted 3GB Heap Memory When Broker Failed

Issue - State: open - Opened by owaiscs001 12 months ago
Labels: :question:need-triage

#385 - Application Pod Crashed: Kafka Producer Exhausted 3GB Heap Memory When Broker Failed

Issue - State: open - Opened by owaiscs001 12 months ago
Labels: :question:need-triage

#384 - Reactor Kafka Producer Not Following Round Robin Assignment

Issue - State: closed - Opened by owaiscs001 12 months ago
Labels: :question:need-triage

#384 - Reactor Kafka Producer Not Following Round Robin Assignment

Issue - State: closed - Opened by owaiscs001 12 months ago
Labels: :question:need-triage

#383 - Micrometer tracing context propagation problem

Issue - State: open - Opened by mzalewski82 about 1 year ago - 1 comment
Labels: :question:need-triage

#383 - Micrometer tracing context propagation problem

Issue - State: open - Opened by mzalewski82 about 1 year ago - 1 comment
Labels: :question:need-triage

#382 - Multiple kafka Consumers in Same Consumer Group receiving same messages

Issue - State: closed - Opened by nayakmk about 1 year ago
Labels: :question:need-triage

#382 - Multiple kafka Consumers in Same Consumer Group receiving same messages

Issue - State: closed - Opened by nayakmk about 1 year ago
Labels: :question:need-triage

#381 - fixed waiting for maxDelayRebalance with AckMode.EXACTLY_ONCE during rebalancing #371

Pull Request - State: open - Opened by damn1kk about 1 year ago - 2 comments

#381 - fixed waiting for maxDelayRebalance with AckMode.EXACTLY_ONCE during rebalancing #371

Pull Request - State: open - Opened by damn1kk about 1 year ago - 2 comments

#380 - Expose manual stop method in KafkaReceiver

Pull Request - State: open - Opened by cjlee38 about 1 year ago - 1 comment

#378 - Provide option for KafkaReceiver's graceful shutdown

Issue - State: open - Opened by cjlee38 about 1 year ago - 4 comments
Labels: :question:need-triage

#377 - Metrics reactor_{receiver|sender}_active{sum|count|bucket} always shows 0

Issue - State: open - Opened by patpatpat123 about 1 year ago - 1 comment
Labels: :question:need-triage

#377 - Metrics reactor_{receiver|sender}_active{sum|count|bucket} always shows 0

Issue - State: open - Opened by patpatpat123 about 1 year ago - 1 comment
Labels: :question:need-triage

#376 - support to read bootstrap server property when it was defined as a list

Pull Request - State: closed - Opened by emmanuelsilva about 1 year ago - 3 comments

#376 - support to read bootstrap server property when it was defined as a list

Pull Request - State: closed - Opened by emmanuelsilva about 1 year ago - 3 comments

#375 - Reactive kafka consumer doesn't pause on calling the consumer.pause() method

Issue - State: open - Opened by manisha-chakraborty about 1 year ago - 3 comments
Labels: :question:need-triage

#374 - ClassCastException on attempt to get bootstrap server from SenderOption/ReceiverOptions

Issue - State: closed - Opened by ajax-osadchuk-r about 1 year ago - 3 comments
Labels: type/bug

#374 - ClassCastException on attempt to get bootstrap server from SenderOption/ReceiverOptions

Issue - State: closed - Opened by ajax-osadchuk-r about 1 year ago - 3 comments
Labels: type/bug

#373 - Allow SenderRecord to take into account existing Observation

Issue - State: closed - Opened by patpatpat123 about 1 year ago - 13 comments
Labels: for/user-attention

#372 - GH-321 / PR 325 - Observation propagation issue, traces are the same while it should not

Issue - State: closed - Opened by patpatpat123 about 1 year ago - 4 comments
Labels: :question:need-triage

#371 - Rebalancing always waits until maxDelayRebalance with AckMode.EXACTLY_ONCE

Issue - State: open - Opened by damn1kk over 1 year ago
Labels: :question:need-triage

#370 - GH-321 / PR 325 - No trace observed in neither log, neither trace aggregation system

Issue - State: closed - Opened by patpatpat123 over 1 year ago - 10 comments
Labels: status/invalid

#370 - GH-321 / PR 325 - No trace observed in neither log, neither trace aggregation system

Issue - State: closed - Opened by patpatpat123 over 1 year ago - 10 comments
Labels: status/invalid

#369 - Documentation Feedback on Reactor Kafka's Observation API

Issue - State: open - Opened by almogtavor over 1 year ago - 6 comments
Labels: for/user-attention

#369 - Documentation Feedback on Reactor Kafka's Observation API

Issue - State: open - Opened by almogtavor over 1 year ago - 6 comments
Labels: for/user-attention

#368 - GH-321 / PR 325 - Observation propagation

Issue - State: open - Opened by janchristian-haddorp over 1 year ago - 4 comments
Labels: :question:need-triage

#368 - GH-321 / PR 325 - Observation propagation

Issue - State: open - Opened by janchristian-haddorp over 1 year ago - 4 comments
Labels: :question:need-triage

#367 - Micrometer Metrics

Issue - State: closed - Opened by janchristian-haddorp over 1 year ago - 3 comments
Labels: status/invalid

#367 - Micrometer Metrics

Issue - State: closed - Opened by janchristian-haddorp over 1 year ago - 3 comments
Labels: status/invalid

#366 - Fix broken example code ('retry(When' -> 'retryWhen')

Pull Request - State: closed - Opened by acktsap over 1 year ago - 1 comment
Labels: type/documentation

#366 - Fix broken example code ('retry(When' -> 'retryWhen')

Pull Request - State: closed - Opened by acktsap over 1 year ago - 1 comment
Labels: type/documentation

#365 - GH-333: Support currentLag() in doOnConsumer

Pull Request - State: closed - Opened by garyrussell over 1 year ago
Labels: type/enhancement

#365 - GH-333: Support currentLag() in doOnConsumer

Pull Request - State: closed - Opened by garyrussell over 1 year ago
Labels: type/enhancement

#364 - Draft for an exactly once processor with support for horizontal scaling

Pull Request - State: closed - Opened by jrhino97 over 1 year ago - 2 comments

#363 - RePause All Partitions After Rebalance if user paused any and requested

Pull Request - State: closed - Opened by Gin2022Null over 1 year ago - 2 comments
Labels: type/enhancement

#363 - RePause All Partitions After Rebalance if user paused any and requested

Pull Request - State: closed - Opened by Gin2022Null over 1 year ago - 2 comments
Labels: type/enhancement

#362 - #360 | Nikhil | Correcting reference doc format error in "Sample Scen…

Pull Request - State: closed - Opened by nikhilkarve over 1 year ago - 6 comments
Labels: type/documentation

#362 - #360 | Nikhil | Correcting reference doc format error in "Sample Scen…

Pull Request - State: closed - Opened by nikhilkarve over 1 year ago - 6 comments
Labels: type/documentation

#361 - Upgrade Kafka Clients Version to 3.6.0

Pull Request - State: closed - Opened by jrhino97 over 1 year ago - 3 comments
Labels: type/dependency-upgrade

#361 - Upgrade Kafka Clients Version to 3.6.0

Pull Request - State: closed - Opened by jrhino97 over 1 year ago - 3 comments
Labels: type/dependency-upgrade

#360 - Reference doc format error in "Sample Scenarios" header

Issue - State: closed - Opened by michaelmcfadyensky over 1 year ago - 4 comments
Labels: type/documentation

#360 - Reference doc format error in "Sample Scenarios" header

Issue - State: closed - Opened by michaelmcfadyensky over 1 year ago - 4 comments
Labels: type/documentation

#359 - Add receive batch to receiver

Pull Request - State: closed - Opened by mohamed-gara over 1 year ago - 2 comments
Labels: type/enhancement

#358 - reactor-kafka docs from 1.3.11 above referencing old 1.1.0.RELEASE docs

Issue - State: closed - Opened by fabiojb over 1 year ago - 4 comments
Labels: type/bug, type/documentation

#358 - reactor-kafka docs from 1.3.11 above referencing old 1.1.0.RELEASE docs

Issue - State: closed - Opened by fabiojb over 1 year ago - 4 comments
Labels: type/bug, type/documentation

#357 - Cannot add partition topic to transaction while in state READY

Issue - State: closed - Opened by yangwenliang123 over 1 year ago - 1 comment
Labels: for/stackoverflow

#356 - Datadog APM Agent compatibility

Issue - State: closed - Opened by AcevedoR over 1 year ago - 1 comment
Labels: for/stackoverflow

#355 - GH-352: Fix IllegalStateException in doOnConsumer()

Pull Request - State: closed - Opened by slimboyfat over 1 year ago - 5 comments

#354 - Add docs for new ReceiverPartition methods

Pull Request - State: closed - Opened by garyrussell over 1 year ago
Labels: type/documentation

#354 - Add docs for new ReceiverPartition methods

Pull Request - State: closed - Opened by garyrussell over 1 year ago
Labels: type/documentation

#353 - Switch to Core SNAPSHOT; Upgrade kafka-clients

Pull Request - State: closed - Opened by garyrussell over 1 year ago
Labels: type/dependency-upgrade

#353 - Switch to Core SNAPSHOT; Upgrade kafka-clients

Pull Request - State: closed - Opened by garyrussell over 1 year ago
Labels: type/dependency-upgrade

#352 - IllegalStateException in KafkaReceiver.doOnConsumer() in case of subsequent subscription.

Issue - State: closed - Opened by slimboyfat over 1 year ago - 2 comments
Labels: type/bug

#351 - GH-344: ReceiverPartition Improvements

Pull Request - State: closed - Opened by garyrussell over 1 year ago

#350 - GH-349: Eagerly Initialize Transactional Producers

Pull Request - State: closed - Opened by garyrussell over 1 year ago

#350 - GH-349: Eagerly Initialize Transactional Producers

Pull Request - State: closed - Opened by garyrussell over 1 year ago

#349 - Transactions have to Timeout for Resubscribe in ExactlyOnce

Issue - State: closed - Opened by jschneider97 over 1 year ago
Labels: type/enhancement

#349 - Transactions have to Timeout for Resubscribe in ExactlyOnce

Issue - State: closed - Opened by jschneider97 over 1 year ago
Labels: type/enhancement

#348 - snappy-java-1.1.8.4.jar (pkg:maven/org.xerial.snappy/[email protected]) : CVE-2023-34455, CVE-2023-34453

Issue - State: closed - Opened by patpatpat123 over 1 year ago - 3 comments
Labels: status/declined

#347 - Consumer lag is always zero

Issue - State: closed - Opened by aqaexplorer over 1 year ago - 1 comment
Labels: status/declined

#347 - Consumer lag is always zero

Issue - State: closed - Opened by aqaexplorer over 1 year ago - 1 comment
Labels: status/declined

#346 - chore(deps): Update dependencies

Pull Request - State: closed - Opened by reneleonhardt over 1 year ago - 4 comments
Labels: status/duplicate

#345 - Topic partition is processing on 2 consumers after consumer group rebalance

Issue - State: open - Opened by ajax-osadchuk-r almost 2 years ago - 12 comments
Labels: for/user-attention

#344 - Add endOffset etc. To ReceiverPartition

Issue - State: closed - Opened by garyrussell almost 2 years ago - 1 comment
Labels: type/enhancement, good first issue