Запросы расширений на использовании сертификатов X509 OpenSSL

Поскольку Kafka предназначен только для добавления, то единственный способ удаления сообщений в этих темах Conncet - это опубликовать его с именем соединителя в качестве ключа сообщения и null в качестве значения.

Вы можете просмотреть эти темы с помощью консоли потребителя, чтобы увидеть, какие данные в них содержатся, включая --property print.key=true, и продолжать работу потребителя при удалении соединителя.

Вы можете PUT новую конфигурацию в /connectors/{name}/config, но любые конкретные смещения, которые используются, зависят от фактического типа разъема (приемник / источник); например, есть внутренняя тема Кафки __consumer_offsets, а также offset.storage.topic. Я не уверен, что изменение connector.class было бы хорошей идеей с учетом этого