License Clarification for Confluent Platform 8.3 Community Edition and JDBC Connector.
I was previously using Apache Kafka 2.0 with 3 node cluster and am currently working on migrating to Confluent Platform 8.3 Community Edition.
Our current setup includes:
- Confluent Platform: 8.3 Community Edition
- Kafka Connect JDBC Connector: 10.9.6
- PostgreSQL JDBC Driver: 42.7.11
- Kafka Cluster: 3-node cluster
Based on the Confluent documentation, my understanding is that the JDBC Connector is covered under the Community License. However, I am currently encountering a license expiry error while running the connector.
Could someone please clarify:
- Whether JDBC Connector 10.9.6 is supported under the Community License with Confluent Platform 8.3.
- Whether any additional license configuration is required for the Community Edition.
- What could be causing the license expiry error in this setup.
- If there are any compatibility or licensing considerations when migrating from Apache Kafka 2.0 to Confluent Platform 8.3 Community Edition.
Any guidance on how to resolve this issue would be greatly appreciated. “Error Details- " http://sm-q-01:8083/connectors/sink-v1hist/status”|jq ‘.’
{
“name”: “sink-v1hist”,
“connector”: {
“state”: “FAILED”,
“worker_id”: “sm-q-03:8083”,
“version”: “10.9.6”,
“trace”: “org.apache.kafka.connect.errors.ConnectException: Error validating license\n\tat org.apache.kafka.connect.runtime.licensing.ConnectWorkerLicenseManager.registerOrValidateWorkerLicense(ConnectWorkerLicenseManager.java:307)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:228)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:259)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:419)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:400)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:176)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:136)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$0(Plugins.java:373)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: io.confluent.license.ExpiredLicensesException: Stored License has expired. Please install a valid license.\n\tat io.confluent.license.LicenseManager.validateFinalLicenseState(LicenseManager.java:863)\n\tat io.confluent.license.LicenseManager.doRegisterOrValidateMultiLicense(LicenseManager.java:671)\n\tat io.confluent.license.LicenseManager.registerOrValidateMultiLicense(LicenseManager.java:625)\n\tat org.apache.kafka.connect.runtime.licensing.ConnectWorkerLicenseManager.registerOrValidateWorkerLicense(ConnectWorkerLicenseManager.java:295)\n\t… 12 more\n”
}