smallrye/smallrye-reactive-messaging

Issues

• Pulsar: out of direct buffer memory during failure handling with nack strategy and DLQ while pool message is enabled.

  #2698 opened 4 months ago by kamilchociej
  1

• 'Targeted' does not support null values

  #2687 opened 5 months ago by marekczajkowski
  1

• Logging password on startup

  #2653 opened 5 months ago by nojomyth-dev
  0

• AWS SQS add support for deleting and sending messages in batch mode

  #2672 opened 5 months ago by arturluzgin
  0

• Kafka Companion: Which is the best way to verify messages are commited?

  #2668 opened 5 months ago by cj19
  1

• Add configuration to outgoing MQTT connector to set retain property

  #2663 opened 5 months ago by diversit
  2

• Azure Role Based Access control with AMQP 1.0

  #2506 opened 5 months ago by antoinechamot
  4

• Kafka Companion clearing the topics for the component tests

  #2658 opened 5 months ago by cj19
  1

• Rabbitmq: Concept of error queues after n retries

  #2641 opened 6 months ago by jonsalvas
  1

• Configuration via env variables not working correctly anymore since Quarkus 3.11

  #2659 opened 5 months ago by panphg
  4

• Support for GenericPayload while returning multiple outgoings

  #2645 opened 5 months ago by pawel-boguski-ds
  3

• Version 3.x problem with Vert.x 4.5.4

  #2647 opened 6 months ago by LucaT75
  6

• Kafka Compaion connects to multiple bootstrap servers at the start of the test

  #2650 opened 5 months ago by cj19
  4

• Suspected memory leak in KafkaThrottledLatestProcessedCommit

  #2623 opened 6 months ago by tilakchowdary
  13

• AWS SQS NACK doing nothing?

  #2635 opened 6 months ago by spc16670
  3

• Disabling RabbitMQ Liveness Checks but not Readiness Checks

  #2552 opened 8 months ago by soframel
  2

• Is not possible to add a custom batchReceivePolicy to the consumer

  #2631 opened 6 months ago by hermeswaldemarin
  3

• Allow conversion to JsonObject to be optional during amqp message deserialization

  #2619 opened 6 months ago by ylepikhov
  1

• IncomingJmsMessage assumes message type it won't be empty

  #2625 opened 6 months ago by neazevedo
  5

• Connect to different brokers per topic - no events are consumed

  #2621 opened 6 months ago by duckdeer
  3

• Kafka batch processing always duplicates multiples of max.poll.records

  #2549 opened 8 months ago by itatdcer
  2

• Messages sent to the DLQ topic are not counted in micrometer metrics.

  #2473 opened 6 months ago by Annlazar
  2

• How to use companion.consumeXYZ() twice?

  #2605 opened 6 months ago by octopus-prime
  2

• Caching dependencies

  #2606 opened 6 months ago by dankristensen
  2

• IncomingConnector has no downstream

  #2593 opened 7 months ago by pengxo
  11

• [Kafka Companion] Assertion of produced messages

  #2590 opened 7 months ago by Inithron
  0

• Kafka consumer gets into a rebalance loop

  #2589 opened 7 months ago by marksouletheprogrammer
  3

• Pulsar blocks vertx thread when blockIfQueueFull is true

  #2548 opened 7 months ago by marekczajkowski
  15

• JMS - Message acknowledgement

  #2575 opened 8 months ago by dankristensen
  2

• Provider: Test AlternativeAnalysisTest fails when running on Windows 11

  #2564 opened 8 months ago by dankristensen
  7

• Kafka delayed retry topic not retrying after initial produce

  #2566 opened 8 months ago by nielsvhaldvb
  4

• Pulsar backpressure mechanism ignores client's memory limit setting

  #2573 opened 8 months ago by marekczajkowski
  0

• Kafka, MutinyEmitter.sendAndAwait context propagation issue

  #2551 opened 8 months ago by mapuci
  0

• smallrye-pulsar cannot publish message in sample Quarkus project

  #2472 opened 8 months ago by vszakd
  10

• Unable to cast message to KafkaRecordBatch

  #2505 opened 8 months ago by nielsvhaldvb
  2

• Enable `KafkaRequestReply` on the same topic

  #2488 opened 8 months ago by iLem0n
  4

• [Kafka Test Companion] Inconsistent handling of properties

  #2489 opened 8 months ago by Abaudat
  1

• GlobalOpenTelemetry instance recreated in Reactive Messaging channels

  #2539 opened 8 months ago by ozangunalp
  2

• There should be a documented way to configure a default connector globally

  #2532 opened 8 months ago by mrickly
  4

• `BlockingWithoutExecutionHolderTest` is flaky

  #2529 opened 8 months ago by ozangunalp
  1

• Pulsar Traces are not always propagated

  #2519 opened 8 months ago by michalcukierman
  1

• Dynamic Outgoing topic for Apache Pulsar

  #2504 opened 8 months ago by vszakd
  3

• Heartbeat mechanism with Smallrye AMQP connector

  #2523 opened 8 months ago by mnguetsa
  1

• Deadlock when using Avro schema with pulsar

  #2513 opened 9 months ago by marekczajkowski
  1

• Can't recover from structured CloudEvents with invalid JSON

  #2492 opened 9 months ago by ntkoopman
  5

• Deadlock when using Avro schema with Pulsar connctor

  #2493 opened 9 months ago by marekczajkowski
  1

• NullPointerException when a non recoverable KafkaException is thrown from the Kafka producer

  #2486 opened 9 months ago by vietk
  1

• Split package `io.smallrye.reactive.messaging.health` between api and health modules

  #2482 opened 9 months ago by ozangunalp
  0

• The `emitter.hasRequests` method does not take into account the buffer size

  #2465 opened 10 months ago by Sgitario
  10

• Pulsar Consumer with Topic Pattern creates a topic using a channel name

  #2467 opened 10 months ago by michalcukierman
  1