По умолчанию сообщения, реплицируемые с использованием исходного соединителя, будут иметь ключ null. Вы можете использовать Kafka SMT , чтобы создать ключ для ваших сообщений. В конфигурации вашего соединителя следующие строки должны помочь (обязательно замените messageId на поле, которое вы хотите использовать в качестве ключа):
transforms=createKey
transforms.createKey.type=org.apache.kafka.connect.transforms.ValueToKey
transforms.createKey.fields=messageId