What can we do to prevent kafka outages?

Any plans on incorporating KIP-932 (KafkaShareConsumer)?

SchemaRegistrySerializationSpec: flaky test

Using pekko-connectors kafka consumer doesn't report exception with schema registry

Test with Kafka 4 server

Apache Pekko based Streaming application is idle and not consuming from kafka topic post rebalancing

Consumer sitting idle not consuming kafka messages from topic

change build so that we link to versioned docs

flaky test: testcontainer didn't start within 60s

`StopFromStage` not delivered