Rafael Acevedo

Expose schema registry errors

1

Hello, Thanks for this great library! I was wondering if there's a simple way to check for "subject not found" errors. I can see that in the `IsRegistered` method, there's...

https://github.com/bsm/sarama-cluster is now deprecated. We should replace it with https://github.com/Shopify/sarama

Publish events before/after consumer start for regular kafka consumers

1

### Feature description Publishing events before and after consumer start is useful for the application to "prepare itself" for receiving records (like loading in-memory caches, for example). I noticed that...

BeanLocator's `findBean(Class<T>, Qualifier<T>)` intermittently not finding `HttpContentSubscriberFactory` with qualifier

1

### Expected Behavior Should find the bean with the qualifier. ### Actual Behaviour Returns empty optional. More details: I observed this happening in `DefaultHttpContentProcessorResolver`, specifically [here](https://github.com/micronaut-projects/micronaut-core/blob/50d40203e886ab9c3ab01413b91d2f57fd20c1d9/http-server-netty/src/main/java/io/micronaut/http/server/netty/DefaultHttpContentProcessorResolver.java). This happens under some...

This makes the `close()` method of `KafkaConsumerProcessor` wait for all consumers to be properly closed Refs #601

Kafka consumer shutdown not waiting for consumer to be closed

1

### Expected Behavior The shutdown process should only proceed to other beans when the consumer is fully closed ### Actual Behaviour When `KafkaConsumerProcessor.close()` is called, it calls `KafkaConsumer.wakeup()`, causing an...

We do not need spark during runtime, so this moves iceberg-spark to the test scope, and adds iceberg dependencies (iceberg-core and iceberg-data)

Speculative execution returning error to user when all replicas are taken by other executions

2

### What version of Cassandra are you using? Scylla 5.1.12 ### What version of Gocql are you using? Latest master ### What version of Go are you using? 1.20 ###...

[jvm] NullPointerException in SnapshotSystemJUnit5

3

HI everyone! Thanks for the amazing project, it really makes jvm testing fun/easy. When using Junit5, I'm intermittently getting the following NullPointerException: ``` java.lang.NullPointerException at com.diffplug.selfie.junit5.SnapshotSystemJUnit5.forClass(SnapshotSystemJUnit5.kt:77) at com.diffplug.selfie.junit5.SelfieTestExecutionListener.executionStarted(SelfieTestExecutionListener.kt:33) ``` When...