John Fallows

**Describe the desired outcome from the user's perspective** As an application developer, I need to transform messages received from a Kafka topic to present via `mqtt-kafka`, `http-kafka` or `sse-kafka` mappings....

Suggested syntax. ``` kafka_cache_server: type: kafka kind: cache_server options: topics: - name: my-transformed-topic transforms: - extract-key: ${message.key.id} ... ```

Use `zilla-demos` `streampay` with connection pool enabled to attempt to reproduce. **Steps to reproduce** 1. git clone https://github.com/aklivity/zilla-demos/tree/main/streampay 2. Go to `streampay/stack` and edit stack.yaml file by removing `, "-Pzilla.binding.kafka.client.connection.pool=false"]`...

AsyncAPI definition requires redefining security scheme to enforce a subset of roles for a specific operation. Propose alternative to simplify authoring security.

**Describe the desired outcome from the user's perspective** As an appdev, I want to use familiar SQL syntax to manage strongly typed Kafka topics and passthrough to other psql endpoint...

Note: consider direct support of `CREATE TABLE` etc here instead of exposing the concept of `topics`. Mappings - [x] `pgsql` `CREATE TOPIC` command to `KafkaCreateTopicsBeginEx` plus `catalog` register new schema...

Kafka client currently supports `mTLS` via TLS client certificates. Review alternative authentication methods and consider adding Kafka client support. - [ ] `SASL / JAAS` - [ ] `SASL /...

Support `psql` binding with `server` and `client` kinds, so that `psql` client can be proxied to a `psql` server. Support route by `command`, such as `CREATE TABLE` or `SELECT` so...

Enhance `CatalogHandler` API to support register new schema version.

Enhance support for Kafka protocol. - `KafkaCreateTopicsBeginEx` - `KafkaAlterConfigsBeginEx` - `KafkaDeleteTopicsBeginEx`