David Mariassy

Copy of [AIRFLOW-5071] JIRA: Thousands of Executor reports task instance X finished (success) although the task says its queued. Was the task killed externally?

56

**Apache Airflow version**: 1.10.9 **Kubernetes version (if you are using kubernetes)** (use `kubectl version`): Server: v1.10.13, Client: v1.17.0 **Environment**: - **Cloud provider or hardware configuration**: AWS - **OS** (e.g. from...

Make reader schemas first class citizens

2

👋🏻 Thanks for maintaining this important piece of software for the community! A few weeks ago I published a [blog post](https://medium.com/@david.mariassy/a-vision-for-managing-kafka-schemas-more-effectively-db042a1eedac) about some of the gaps I see in Kafka's...

Support for deterministic ID strategy to simplify recovery from corrupted registry state?

2

### Feature or Problem Description Imagine the following scenario: 1. An operator accidentally `TRUNCATE`s all registry data in Postgres 1. Kafka producers continue to run, and re-register the schemas during...

Right now, the service only assign a reviewer to the generated PR if the repo contains a `CODEOWNERS` file. It would be great if the PRs would also get assigned...

[FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format

16

## What is the purpose of the change - Add support for deserializing protobuf messages using the Confluent wire format and whose schemas can be fetched from Confluent Schema Registry...

> Hi, > > We have tried to do a mass clean up of our SR instance, and deleted a ton of subjects with `?permanent=true`. These requests produced the expected...

Upstream connection pool per virtual cluster

5

**Is your feature request related to a problem? Please describe.** We have many Kafka producers that run in a fork-based concurrency model and each worker maintains its own Kafka connections....