Bug report

For bug reports, provide this information, please:

What Debezium connector do you use and what version?

Informix Debezium Connector and the version was 2.5.0

What is the connector configuration?

I am using the sample Informix connector configurations given in the debezium's official documentation version 2.5 under the Informix Connector Deployment section. 

{ "connector.class": "io.debezium.connector.informix.InformixConnector", "database.hostname": "192.168.99.100", "database.port": "9088", "database.user": "informix", "database.password": "in4mix", "database.dbname": "mydatabase", "topic.prefix": "fullfillment", "table.include.list": "myschema.customers", "schema.history.internal.kafka.bootstrap.servers": "kafka:9092", "schema.history.internal.kafka.topic": "schemahistory.fullfillment" }

What is the captured database version and mode of deployment?

I am using the below versions of Informix and I am using the KAFKA Connect UI for Debezium connector deployment. 

Informix Dynamic Server
14.10.FC10W1X2
Informix JDBC Driver for Informix Dynamic Server
4.50.JC10

What behaviour do you expect?

I expect the new connector to be deployed and ready for data capture. 

What behaviour do you see?

I face an Invalid Configuration error on the KAFKA Connect UI and in the logs the connector is not being recognized. 

 

[2024-01-26 19:02:09,201] ERROR Uncaught exception in REST call to /connectors (org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper:61)
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.debezium.connector.informix.InformixConnector, available connectors are: PluginDesc{klass=class io.confluent.connect.jdbc.JdbcSinkConnector, name='io.confluent.connect.jdbc.JdbcSinkConnector', version='10.7.3-5', encodedVersion=10.7.3-5, type=sink, typeName='sink', location='file:/u/kafka_BI/share/confluentinc-kafka-connect-jdbc/lib/'}, PluginDesc{klass=class io.confluent.connect.jdbc.JdbcSourceConnector, name='io.confluent.connect.jdbc.JdbcSourceConnector', version='10.7.3-5', encodedVersion=10.7.3-5, type=source, typeName='source', location='file:/u/kafka_BI/share/confluentinc-kafka-connect-jdbc/lib/'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorCheckpointConnector, name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector, name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector, name='org.apache.kafka.connect.tools.MockSinkConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector, name='org.apache.kafka.connect.tools.MockSourceConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector, name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector, name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector, name='org.apache.kafka.connect.tools.VerifiableSourceConnector', version='7.4.1-ce', encodedVersion=7.4.1-ce, type=source, typeName='source', location='classpath'}
    at org.apache.kafka.connect.runtime.isolation.Plugins.connectorClass(Plugins.java:253)
    at org.apache.kafka.connect.runtime.isolation.Plugins.newConnector(Plugins.java:224)
    at org.apache.kafka.connect.runtime.AbstractHerder.lambda$getConnector$8(AbstractHerder.java:780)
    at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
    at org.apache.kafka.connect.runtime.AbstractHerder.getConnector(AbstractHerder.java:780)
    at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:530)
    at org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$4(AbstractHerder.java:449)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:750)
[2024-01-26 19:02:09,241] INFO 172.20.0.2 - - [26/Jan/2024:14:02:08 +0000] "POST /connectors HTTP/1.1" 500 2635 "-" "ReactorNetty/1.1.6" 307 (org.apache.kafka.connect.runtime.rest.RestServer:62)

Do you see the same behaviour using the latest relesead Debezium version?

Yes, I am facing the same error when I have used the jars provided in version 2.6 Alpha jars and in version 2.5 Final jars. 

Do you have the connector logs, ideally from start till finish?

Please note that I have included the directory of where the Debezium Informix jar files are in the plugin and use the below command for that properties file execution. 

PLUGIN PATH IN THE PROPERTIES FILE. 

plugin.path=/u/kafka_BI/share/confluentinc-kafka-connect-jdbc,/u/kafka_BI/share/official_informix_connector,/u/kafka_BI/share/confluentinc-connect-transforms-1.4.3{}

 

Command used for Deployment of JARs: **

 ./connect-distributed -daemon ../etc/kafka/connect-distributed.properties

 
The complete logs has been attached in this Jira "Debezium Kafka Logs"