Missing Kafka Connect Configuration - Debezium Specific

[Argonus]

Overview

Some of the Debezium Kafka Connect configurations are missing in AKHQ. It looks like all missing entries are the ones that have been added as breaking changes between versions v1.4 and v2.4

Setup

Debezium Version: v2.4
Kafka Connect Version: v7.4.2
AKHQ Version: v0.24.0

Example Missing Entries

It looks like they all are from topic group.

  topic.heartbeat.prefix (renamed from heartbeat.topics.prefix)
  topic.creation.enabled
  topic.creation.default.partitions
  topic.creation.default.replication.factor

Help

I can help with adding new missing config options, but I can't find any configuration in this repo. Shouldn't it be autoloaded somehow, as the older custom Debezium configuration is working?

[AlexisSouquiere]

I'm not really familiar with the connect definitions feature but for me yes all the metadata are loaded automatically here:

akhq/src/main/java/org/akhq/repositories/ConnectRepository.java

Lines 72 to 75 in 81933ca

	ConnectorsWithExpandedMetadata unfiltered = this.kafkaModule
	.getConnectRestClient(clusterId)
	.get(connectId)
	.getConnectorsWithAllExpandedMetadata();

I don't have time on my side but maybe you should try with the dev branch where the connect client has been updated

[Argonus]

Thank you, will take a look at it in next few weeks, as I' finally moved to work on Kafka at my current workplace :)