smallrye-reactive-messaging
smallrye-reactive-messaging copied to clipboard
smallrye
SmallRye Reactive Messaging
``` Errors: Error: KafkaRequestReplyTest.testReplyOffsetResetEarliest:447 » ConditionTimeout Assertion condition Expected size: 10 but was: 3 in: ["7", "8", "9"] within 10 seconds. ```
The configuration for `max-outstanding-messages` seems to be applied only during the initial connection of the application. After the connection is being restarted the RabbitMQ consumer's prefetch size is always 0....
Is it possible to have different failure management strategies for the same connector? An example of why this would be useful in a kube environment: - If the message processing...
Hello, I have a strange behavior with my Quarkus application (v. 2.16.7.Final) using Smallrye Reactive Messaging with Apache Camel connector and Camel file component. The application is very simple, with...
When trying to push an outgoing message with null key to a compacted topic, smallrye will retry in a loop for ~60-120 seconds before nacking and returning an InvalidRecordException. The...
Hello folks, we have a case where we need to scale (vertical) our exactly once consumer-producer chain. For example we have 10 partitions and we would like to read the...
While exploring the Kafka connector in SmallRye Reactive Messaging, I found that the documentation doesn't clearly specify the default behavior of the rebalance handler when the "throttled" commit strategy is...
Hi 🙋, ## ? Context We process records in batch and we want to send **only** poisoned records to a [`dead-letter-queue`](https://smallrye.io/smallrye-reactive-messaging/4.9.0/kafka/receiving-kafka-records/#dead-letter-queue) in case of failure, not [_all_ the records in...
Whats the recommended solution for using JMS connector from within WildFly with its embedded ActiveMQ server? Using the connector with default ConnectionFactory does not work ``` @ApplicationScoped public class JmsConnectionFactory...
In JMS "Sending JMS messages" section, Serde link is getting 404: https://smallrye.io/smallrye-reactive-messaging/4.10.0/jms/sending-jms-messages/#example Doc link here: https://github.com/smallrye/smallrye-reactive-messaging/blob/b2124a790f368b2f9ed4d795ae1002e1bf169351/documentation/src/main/docs/jms/sending-jms-messages.md Earliest working one we found was from 3.1: https://smallrye.io/smallrye-reactive-messaging/smallrye-reactive-messaging/3.1/jms/serde
