Loïc Mathieu
Loïc Mathieu
This is a prototype to be able to consume AVRO messages via karate-kafka. I tested it locally and it works. Please give feedback wether or not this is something that...
Consumer `group.id` should not be set by default. When you launch a scenario a first with a consumer group set via `group.id` Kafka will register the offset read by this...
This allow it to be compatible with Confluent Schema Registry
When we use multiple JUnit5 extensions, the way to order them is via the `@ExtendsWith({FirstExtension.class, SecondExtension.class})` annotation. But `TestcontainersExtension` is not public so we can only use the `@Testcontainers` annotion...
**Describe the bug** SQL annotations didn't work with Quarkus starting with 1.3. No issues are detected. I chased down the issue to `SqlRecorderRegistry` that uses an `InheritableThreadLocal` to stores the...
**Describe the bug** Today, due to a limitation on JUnit 5 dynamic test interceptor support, we cannot implement the support of dynamic tests for JVM annotations. This should be fixed...
**Description** Add `@MeasureMetaspaceAllocation` to be able to mesure memory allocation on the Metaspace memory pool. Add `@ExpectMetaspaceAllocation` to be able to put expectation on the result of `@MeasureMetaspaceAllocation` and use...
### Proposal Today, Kafka scaler only allow to scale based on the lag of one topic. A lot of streaming applications uses multiple topics, using the Kafka scaler can be...
`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...
Kafka Transaction support is usefull to provides: - Atomic send of multiple messages - Atomic consume / send of two messages to provides "processor" semantic (a component that reads from...