smallrye-reactive-messaging

smallrye-reactive-messaging copied to clipboard

Bump opentelemetry.version from 1.16.0 to 1.17.0

1

Bumps `opentelemetry.version` from 1.16.0 to 1.17.0. Updates `opentelemetry-api` from 1.16.0 to 1.17.0 Release notes Sourced from opentelemetry-api's releases. Version 1.17.0 API API Extensions DEPRECATION: the opentelemetry-extension-annotations module containing @WithSpan and...

dependabot[bot]

Kafka - NPE with CloudEvents enabled and a null header value

1

When consuming a Kafka record with CloudEvents enabled the current implementation in the KafkaCloudEventHelper breaks when a header with no value is present. The problematic code is: ``` // Build...

lostiniceland

fixes #1848 Null values in a header-value can break the UTF-8 String conversion, causing the Channel to be unhealthy.

lostiniceland

Kafka consume stopped without any exception log

11

### Problem description My Kafka consumers will occasionally stop consuming, Consumers are distributed across multiple machine nodes, and each node is configured with multiple consuming threads (partitions>1). Once in a...

liuzhaozhao

Kafka commit and failure SPI

1

ozangunalp

Kafka Companion: always pass the failure to the AssertionError

1

`RecordsSubscriber` did not pass the original throwable to the `AssertionError` in all cases so debugging a failure (like a mis-configuration) is hard (we need to use a debugger). This PR...

loicmathieu

Hi, I am using Smallrye for rabbitmq in a service that is a consumer. Every time I restart the service I got some issues related to the rabbitmq connection. 2022-08-09...

leoee

Hi, According to the [documentation](https://smallrye.io/smallrye-reactive-messaging/smallrye-reactive-messaging/3.11/rabbitmq/rabbitmq.html), the values for rabbitmq-reconnect-interval is seconds. During some uses, I realized the time is actually in milliseconds.

leoee

Mutiny 1.7.0 with no prefetch concatmap

6

- Bump mutiny to 1.7.0 - The hack needed for avoiding buffering is no longer needed - Messages nacked when MessageConverter throws exception

ozangunalp

Kafka Companion design makes tests dependent on each other

1

Current approach to Kafka Companion does not provide out of the box solution for running independent test cases on same Companion instance within same topic. Imagine, that you write multiple...

Nidum