reactor/reactor-kafka issues and pull requests

#343 - GraalVM/native/AOT Caused by: java.lang.NoSuchMethodException: org.apache.kafka.common.serialization.StringDeserializer.<init>()

Issue - State: closed - Opened by patpatpat123 almost 2 years ago - 2 comments
Labels: status/invalid

#342 - Consumer pro-actively leaving the group and Kafka consumer has been closed

Issue - State: closed - Opened by hirenbharadwa almost 2 years ago - 2 comments
Labels: for/stackoverflow

#341 - KafkaProducer#close() seems to leak Kafka resources.

Issue - State: open - Opened by basking2 almost 2 years ago - 9 comments
Labels: :question:need-triage

#340 - Kafka consumer unable to connect to Kafka after Kafka restart

Issue - State: open - Opened by Avinashshetty44 almost 2 years ago - 1 comment
Labels: :question:need-triage

#339 - Kafka Consumer memory Leak

Issue - State: open - Opened by jilsonjoseph almost 2 years ago - 1 comment
Labels: for/user-attention

#338 - Clarification on reactor.kafka.receiver.internals.ConsumerEventLoop.PollEvent<K, V> code

Issue - State: closed - Opened by gauravsindhwani almost 2 years ago - 2 comments
Labels: for/stackoverflow

#337 - newArgumentParser was deprecated

Pull Request - State: closed - Opened by s50600822 almost 2 years ago - 1 comment

#336 - Consumer does not rejoin group after heartbeat timeout

Issue - State: open - Opened by 62mkv almost 2 years ago - 7 comments
Labels: :question:need-triage

#335 - documentation: clarify "commit during rebalance"

Issue - State: open - Opened by 62mkv almost 2 years ago
Labels: :question:need-triage

#334 - Behaviour of ReceiverOptions.addAssignListener changed

Issue - State: open - Opened by gorkemaygul almost 2 years ago - 3 comments
Labels: :question:need-triage

#333 - Support currentLag() in doOnConsumer

Issue - State: closed - Opened by gzahl almost 2 years ago - 1 comment
Labels: type/enhancement

#332 - Concurrency set to > 1 still have one reactor thread only consuming from multiple partitions

Issue - State: open - Opened by patpatpat123 almost 2 years ago - 6 comments
Labels: type/enhancement

#331 - reactor-kafka 1.3.17 [reactor-kafka-sender] reactor.core.publisher.Operators : Operator called default onErrorDropped reactor.core.Exceptions$ErrorCallbackNotImplemented: reactor.core.Exceptions$OverflowException: Could not emit buffer due to lack of requests

Issue - State: closed - Opened by patpatpat123 almost 2 years ago - 5 comments
Labels: for/user-attention

#330 - [Enhancement request] reactiveKafkaConsumerTemplate.receiveAutoAck() => Flux<ConsumerRecord<String, String>> vs kafkaReceiver.receiveAutoAck() => Flux<Flux<ConsumerRecord<String, String>>

Issue - State: closed - Opened by patpatpat123 almost 2 years ago - 4 comments
Labels: type/documentation

#329 - reactor.kafka.receiver.KafkaReceiverTest fails from time to time

Issue - State: open - Opened by violetagg almost 2 years ago
Labels: type/bug

#328 - GH-327: Catch WakeupException on syncCommit()

Pull Request - State: closed - Opened by garyrussell almost 2 years ago

#328 - GH-327: Catch WakeupException on syncCommit()

Pull Request - State: closed - Opened by garyrussell almost 2 years ago

#327 - Unexpected exception with receiveAtmostOnce

Issue - State: closed - Opened by vinsguru almost 2 years ago - 2 comments
Labels: type/bug

#327 - Unexpected exception with receiveAtmostOnce

Issue - State: closed - Opened by vinsguru almost 2 years ago - 2 comments
Labels: type/bug

#326 - enable.auto.commit is always set to false

Issue - State: closed - Opened by vinsguru almost 2 years ago - 1 comment
Labels: for/stackoverflow

#325 - GH-321: Add Observation propagation

Pull Request - State: closed - Opened by artembilan about 2 years ago - 39 comments
Labels: type/enhancement

#324 - JoinGroup failed: The coordinator is not aware of this member error during startup - Reactive Kafka consumer subscribe

Issue - State: open - Opened by rguntu about 2 years ago - 7 comments
Labels: :question:need-triage, for/user-attention

#324 - JoinGroup failed: The coordinator is not aware of this member error during startup - Reactive Kafka consumer subscribe

Issue - State: open - Opened by rguntu about 2 years ago - 7 comments
Labels: :question:need-triage, for/user-attention

#323 - Add Micrometer Support for Consumer and Producer

Pull Request - State: closed - Opened by crigas1 about 2 years ago - 8 comments

#322 - Fix invasive logging (#309)

Pull Request - State: closed - Opened by kotlinlukas about 2 years ago - 4 comments

#322 - Fix invasive logging (#309)

Pull Request - State: closed - Opened by kotlinlukas about 2 years ago - 4 comments

#321 - Reactor Core + reactor-core-micrometer + context-propagation + tap, still no trace ID seen

Issue - State: closed - Opened by patpatpat123 about 2 years ago - 16 comments
Labels: type/enhancement

#321 - Reactor Core + reactor-core-micrometer + context-propagation + tap, still no trace ID seen

Issue - State: open - Opened by patpatpat123 about 2 years ago - 15 comments
Labels: :question:need-triage

#320 - Topic has lag when application consume completed

Issue - State: closed - Opened by sogreatsg about 2 years ago - 7 comments
Labels: for/user-attention

#320 - Topic has lag when application consume completed

Issue - State: closed - Opened by sogreatsg about 2 years ago - 7 comments
Labels: for/user-attention

#319 - After pausing partition (and stopping it's processing), then seeking and resuming it my Flux is empty

Issue - State: open - Opened by texhnolyzze about 2 years ago - 1 comment
Labels: for/user-attention

#319 - After pausing partition (and stopping it's processing), then seeking and resuming it my Flux is empty

Issue - State: open - Opened by texhnolyzze about 2 years ago - 1 comment
Labels: for/user-attention

#318 - Added disable hook after each test

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

#317 - Reactor Kafka: Tracing - Complete example with reactive Producer + reactive Consumer traces

Issue - State: closed - Opened by patpatpat123 about 2 years ago - 2 comments
Labels: :question:need-triage

#317 - Reactor Kafka: Tracing - Complete example with reactive Producer + reactive Consumer traces

Issue - State: closed - Opened by patpatpat123 about 2 years ago - 2 comments
Labels: :question:need-triage

#316 - Added prefetch to flatMapIterable. Resolves #313

Pull Request - State: closed - Opened by rgrebski about 2 years ago - 7 comments

#316 - Added prefetch to flatMapIterable. Resolves #313

Pull Request - State: closed - Opened by rgrebski about 2 years ago - 7 comments

#315 - GH-314: Fix Cooperative Incremental Rebalance

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

#315 - GH-314: Fix Cooperative Incremental Rebalance

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

#314 - KafkaReceiver fails to rebalance with CooperativeStickyAssignor

Issue - State: closed - Opened by alopukhov about 2 years ago - 5 comments
Labels: :question:need-triage, for/user-attention

#314 - KafkaReceiver fails to rebalance with CooperativeStickyAssignor

Issue - State: closed - Opened by alopukhov about 2 years ago - 5 comments
Labels: :question:need-triage, for/user-attention

#313 - Hooks.onEachOperator with Operators.lift break backpressure / prefetch

Issue - State: closed - Opened by rgrebski about 2 years ago - 5 comments
Labels: :question:need-triage

#313 - Hooks.onEachOperator with Operators.lift break backpressure / prefetch

Issue - State: closed - Opened by rgrebski about 2 years ago - 5 comments
Labels: :question:need-triage

#312 - Hooks.onEachOperator with Operators.lift break backpressure/prefetch/queue size

Issue - State: closed - Opened by rgrebski-ah about 2 years ago - 2 comments
Labels: :question:need-triage

#312 - Hooks.onEachOperator with Operators.lift break backpressure/prefetch/queue size

Issue - State: closed - Opened by rgrebski-ah about 2 years ago - 2 comments
Labels: :question:need-triage

#311 - Use new `GitHub Actions` API for setting output

Pull Request - State: closed - Opened by violetagg about 2 years ago
Labels: type/chore

#311 - Use new `GitHub Actions` API for setting output

Pull Request - State: closed - Opened by violetagg about 2 years ago
Labels: type/chore

#310 - Wanted to know if there is any way we can modify existing flux to receive messages at slower rate

Issue - State: closed - Opened by varunyy about 2 years ago - 1 comment
Labels: for/stackoverflow

#310 - Wanted to know if there is any way we can modify existing flux to receive messages at slower rate

Issue - State: closed - Opened by varunyy about 2 years ago - 1 comment
Labels: for/stackoverflow

#309 - Remove invasive error-logging in DefaultKafkaSender / SendProducer.java

Issue - State: closed - Opened by kotlinlukas about 2 years ago - 3 comments
Labels: type/enhancement, good first issue

#309 - Remove invasive error-logging in DefaultKafkaSender / SendProducer.java

Issue - State: closed - Opened by kotlinlukas about 2 years ago - 3 comments
Labels: type/enhancement, good first issue

#308 - Facing Constant Rebalancing and not becoming Stable

Issue - State: open - Opened by VijayIndia about 2 years ago - 2 comments
Labels: :question:need-triage

#307 - Add Option to Pause All After Rebalance

Issue - State: closed - Opened by garyrussell about 2 years ago - 7 comments
Labels: type/enhancement

#306 - RePause User Paused Partitions After Rebase

Pull Request - State: closed - Opened by garyrussell about 2 years ago - 6 comments

#306 - RePause User Paused Partitions After Rebase

Pull Request - State: closed - Opened by garyrussell about 2 years ago - 6 comments

#305 - Rebalance resume consumer after user pause

Issue - State: closed - Opened by Gin2022Null about 2 years ago
Labels: type/bug

#305 - Rebalance resume consumer after user pause

Issue - State: closed - Opened by Gin2022Null about 2 years ago
Labels: type/bug

#304 - Consumption paused indefinitely with out of order commit enabled

Issue - State: open - Opened by Gin2022Null about 2 years ago - 5 comments
Labels: :question:need-triage

#304 - Consumption paused indefinitely with out of order commit enabled

Issue - State: open - Opened by Gin2022Null about 2 years ago
Labels: :question:need-triage

#303 - Access to offset metadata while committing record

Issue - State: open - Opened by sourabhdug about 2 years ago
Labels: type/enhancement

#303 - Access to offset metadata while committing record

Issue - State: open - Opened by sourabhdug about 2 years ago
Labels: type/enhancement

#302 - GH-301: Improve Partitions Resumed Log

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

#302 - GH-301: Improve Partitions Resumed Log

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

#301 - Do not emit the `Resumed` log if no partitions are actually resumed

Issue - State: closed - Opened by garyrussell about 2 years ago
Labels: type/bug

#301 - Do not emit the `Resumed` log if no partitions are actually resumed

Issue - State: closed - Opened by garyrussell about 2 years ago
Labels: type/bug

#300 - Improve ack throughput with deferred commits

Pull Request - State: closed - Opened by pdanelson over 2 years ago - 4 comments

#300 - Improve ack throughput with deferred commits

Pull Request - State: closed - Opened by pdanelson over 2 years ago - 4 comments

#299 - Improve acknowledgement throughput when utilising deferred commits under high load

Issue - State: closed - Opened by pdanelson over 2 years ago - 2 comments
Labels: for/user-attention

#299 - Improve acknowledgement throughput when utilising deferred commits under high load

Issue - State: closed - Opened by pdanelson over 2 years ago - 2 comments
Labels: for/user-attention

#298 - producer is not releasing memory occupied by byte[]

Issue - State: open - Opened by kuldeep992 over 2 years ago
Labels: :question:need-triage

#298 - producer is not releasing memory occupied by byte[]

Issue - State: open - Opened by kuldeep992 over 2 years ago
Labels: :question:need-triage

#297 - Consumption is paused indefinitely

Issue - State: open - Opened by Arun-test over 2 years ago - 7 comments
Labels: type/bug, type/documentation

#297 - Consumption is paused indefinitely

Issue - State: open - Opened by Arun-test over 2 years ago - 7 comments
Labels: type/bug, type/documentation

#296 - Out of the box support for consuming requests within specified timestamps

Issue - State: open - Opened by rishavjayswal over 2 years ago - 1 comment
Labels: for/user-attention

#296 - Out of the box support for consuming requests within specified timestamps

Issue - State: open - Opened by rishavjayswal over 2 years ago - 1 comment
Labels: for/user-attention

#295 - Error after consumer reconnect "Transaction offset Commit failed due to consumer group metadata mismatch: Specified group generation id is not valid."

Issue - State: open - Opened by damn1kk over 2 years ago
Labels: :question:need-triage

#295 - Error after consumer reconnect "Transaction offset Commit failed due to consumer group metadata mismatch: Specified group generation id is not valid."

Issue - State: open - Opened by damn1kk over 2 years ago
Labels: :question:need-triage

GitHub / reactor/reactor-kafka issues and pull requests