reactor/reactor-kafka

Issues

• Provide option for KafkaReceiver's graceful shutdown

  #378 opened 5 months ago by cjlee38
  3

• reactor.kafka.receiver.internals.MockReceiverTest > consumerMethods FAILED

  #389 opened 3 months ago by chemicL
  0

• Reactor Kafka Producer Not Following Round Robin Assignment

  #384 opened 3 months ago by owaiscs001
  0

• Consumption stopped with slow consumer

  #386 opened 3 months ago by abialas
  0

• Application Pod Crashed: Kafka Producer Exhausted 3GB Heap Memory When Broker Failed

  #385 opened 4 months ago by owaiscs001
  0

• Micrometer tracing context propagation problem

  #383 opened 4 months ago by mzalewski82
  1

• GH-321 / PR 325 - Observation propagation

  #368 opened 8 months ago by janchristian-haddorp
  4

• Multiple kafka Consumers in Same Consumer Group receiving same messages

  #382 opened 5 months ago by nayakmk
  0

• Metrics reactor_{receiver|sender}_active{sum|count|bucket} always shows 0

  #377 opened 6 months ago by patpatpat123
  1

• ClassCastException on attempt to get bootstrap server from SenderOption/ReceiverOptions

  #374 opened 5 months ago by ajax-osadchuk-r
  3

• Expose KafkaConsumer in ReceiverOptionsCustomizer.addAssignListener() - parity with KafkaBindingRebalanceListener

  #379 opened 5 months ago by mvazquezrius
  0

• Reactive kafka consumer doesn't pause on calling the consumer.pause() method

  #375 opened 6 months ago by manisha-chakraborty
  0

• Allow SenderRecord to take into account existing Observation

  #373 opened 6 months ago by patpatpat123
  13

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

  #372 opened 7 months ago by patpatpat123
  4

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

  #370 opened 7 months ago by patpatpat123
  10

• Documentation Feedback on Reactor Kafka's Observation API

  #369 opened 8 months ago by almogtavor
  6

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

  #321 opened 8 months ago by patpatpat123
  16

• Rebalancing always waits until maxDelayRebalance with AckMode.EXACTLY_ONCE

  #371 opened 7 months ago by damn1kk
  0

• Micrometer Metrics

  #367 opened 8 months ago by janchristian-haddorp
  3

• Support currentLag() in doOnConsumer

  #333 opened 8 months ago by gzahl
  1

• Reference doc format error in "Sample Scenarios" header

  #360 opened 8 months ago by michaelmcfadyensky
  4

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

  #358 opened 10 months ago by fabiojb
  4

• Cannot add partition topic to transaction while in state READY

  #357 opened 10 months ago by yangwenliang123
  1

• Datadog APM Agent compatibility

  #356 opened a year ago by AcevedoR
  1

• IllegalStateException in KafkaReceiver.doOnConsumer() in case of subsequent subscription.

  #352 opened a year ago by slimboyfat
  2

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

  #324 opened a year ago by rguntu
  7

• Topic partition is processing on 2 consumers after consumer group rebalance

  #345 opened a year ago by ajax-osadchuk-r
  12

• Add endOffset etc. To ReceiverPartition

  #344 opened a year ago by garyrussell
  1

• Transactions have to Timeout for Resubscribe in ExactlyOnce

  #349 opened a year ago by jschneider97
  0

• snappy-java-1.1.8.4.jar (pkg:maven/org.xerial.snappy/snappy-java@1.1.8.4) : CVE-2023-34455, CVE-2023-34453

  #348 opened a year ago by patpatpat123
  3

• Consumer lag is always zero

  #347 opened a year ago by aqaexplorer
  1

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

  #343 opened a year ago by patpatpat123
  2

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

  #342 opened a year ago by hirenbharadwa
  2

• KafkaProducer#close() seems to leak Kafka resources.

  #341 opened a year ago by basking2
  9

• Kafka consumer unable to connect to Kafka after Kafka restart

  #340 opened a year ago by Avinashshetty44
  1

• Kafka Consumer memory Leak

  #339 opened a year ago by jilsonjoseph
  1

• Clarification on reactor.kafka.receiver.internals.ConsumerEventLoop.PollEvent<K, V> code

  #338 opened a year ago by gauravsindhwani
  2

• Consumer does not rejoin group after heartbeat timeout

  #336 opened a year ago by 62mkv
  7

• documentation: clarify "commit during rebalance"

  #335 opened a year ago by 62mkv
  0

• Behaviour of ReceiverOptions.addAssignListener changed

  #334 opened a year ago by gorkemaygul
  3

• Concurrency set to > 1 still have one reactor thread only consuming from multiple partitions

  #332 opened a year ago by patpatpat123
  6

• 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

  #331 opened a year ago by patpatpat123
  5

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

  #330 opened a year ago by patpatpat123
  4

• reactor.kafka.receiver.KafkaReceiverTest fails from time to time

  #329 opened a year ago by violetagg
  0

• Topic has lag when application consume completed

  #320 opened a year ago by sogreatsg
  7

• Unexpected exception with receiveAtmostOnce

  #327 opened a year ago by vinsguru
  2

• enable.auto.commit is always set to false

  #326 opened a year ago by vinsguru
  1

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

  #317 opened a year ago by patpatpat123
  2

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

  #319 opened a year ago by texhnolyzze
  1

• KafkaReceiver fails to rebalance with CooperativeStickyAssignor

  #314 opened a year ago by alopukhov
  5