Yaroslav Tkachenko

I honestly didn't expect `undeploy` to delete the namespace I'm using. Is it really necessary? The namespace can contain other non-Flink related resources (like secrets).

[FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

3

## What is the purpose of the change Adding a way to configure `client.id.prefix` for the KafkaSink, which, internally, configures `client.id` for the KafkaProducer. This implementation essentially copies the implementation...

Feature Request: adding, updating and deleting schemas in the Schema Registry

1

Currently, the Schema Registry is read-only. It'd be great to allow creating, updating and deleting schemas.

Don't add trailing slash to the base URL

2

Currently, it's not possible to provide URLs with additional parameters like `?ssl=true` because of the trailing slash. The slash is not needed: baseUrl is primarily used by `ClickHouseUtil.getJdbcUrl`, which [adds...

I'd like to be able to extend `ClickHouseCatalog` in my project and changing some of the internal `private` fields to `protected` seems like a fairly non-disruptive thing.

Switch to a MySQL image with arm64 support

1

Closes #1367 [The official MySQL distribution](https://www.mysql.com/de/support/supportedplatforms/database.html) doesn't support arm64 architecture for 5.7, so it's not possible to run tests on an Apple Silicon machine natively. https://github.com/biarms/mysql is a distribution that's...

RecordField w/ timestamp.field should support nested timestamps inside maps

3

Similarly to https://github.com/confluentinc/kafka-connect-storage-common/issues/47 I have a nested timestamp field. However it's nested inside a map, for example, like this: ```java Schema schema = SchemaBuilder.struct() .field("headers", SchemaBuilder.map(Schema.STRING_SCHEMA, Schema.STRING_SCHEMA)) .field("data", Schema.BYTES_SCHEMA) .build();...

So any custom external endpoint can be added, e.g. links to repos.

Will probably require more configuration for discovering resources.