smallrye-reactive-messaging

smallrye-reactive-messaging copied to clipboard

Add basic support for AWS SQS - send and read

1

Hi team, this is my first PR to this project, please guide me through any project-specific protocols or conventions that I might overlook, 🙇 I noticed there is already one...

cuichenli

Upgrade to Mutiny 2.6.0 with JCTools

8

jponge

Bumps [io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha](https://github.com/open-telemetry/opentelemetry-java-instrumentation) from 1.31.0-alpha to 2.2.0-alpha. Release notes Sourced from io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha's releases. Version 2.1.0 This release targets the OpenTelemetry SDK 1.35.0. Note that many artifacts have the -alpha suffix attached...

dependabot[bot]

Azure Role Based Access control with AMQP 1.0

2

Hi, I need to use smallrye with Azure service Bus. For security reasons, I can only use the recommended [passwordless connections using Role Based Access control ](https://learn.microsoft.com/en-us/azure/service-bus-messaging/service-bus-migrate-azure-credentials?tabs=dotnet%2Croles-azure-portal%2Csign-in-azure-cli%2Cservice-connector%2Cservice-connector-identity%2Cassign-role-service-connector) Is it possible...

antoinechamot

smallrye-pulsar cannot publish message in sample Quarkus project

9

Hello, I have a very simple demo project, made following the Quarkus quickstarts. The project cannot publish because of this error: ``` WARN [org.apa.pul.cli.imp.ProducerImpl] (vert.x-eventloop-thread-5) [quote-requests] [external-out] error while create...

vszakd

Unable to cast message to KafkaRecordBatch

1

Whenever i try to use the KafkaRecordBatch object as Incoming item i get the following error: > ERROR [io.sma.rea.mes.provider] (vert.x-eventloop-thread-0) SRMSG00200: The method nl.devolksbank.capability.transactioninsights.transaction.BatchTransactionLoader#processBoekingBatch has thrown an exception: java.lang.ClassCastException: class...

nielsvhaldvb

Needs more work.

ozangunalp

Seek to beginning or reset offset to 0 to reconsume a Kafka topic

2

When we make a boo boo while consuming topics, sometimes we want to re-consume the whole topic. SmallRye Reactive Messaging does not support this (at least on Kafka?). Our current...

scspijker

Can't recover from structured CloudEvents with invalid JSON

5

When receiving a structured CloudEvent, the payload is converted to JSON by [KafkaCloudEventHelper#createFromStructuredCloudEvent](https://github.com/smallrye/smallrye-reactive-messaging/blob/main/smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/ce/KafkaCloudEventHelper.java#L80). If the actual data is not valid JSON, this throws an exception which is handled in [KafkaSource](https://github.com/smallrye/smallrye-reactive-messaging/blob/main/smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/KafkaSource.java#L191)...

ntkoopman

Enable `KafkaRequestReply` on the same topic

4

Are you planning the `KafkaRequestReply` to work on the same topic? What I currently see is the need of two distinct topic for the logic to work, we have several...

iLem0n