New to KubeDB? Please start here.

Supported Kafka Features

FeaturesKafkaConnectCluster
Clustering - Combined (shared controller and broker nodes)-
Clustering - Topology (dedicated controllers and broker nodes)-
Custom Configuration
Automated Version Update
Automatic Vertical Scaling
Automated Horizontal Scaling
Automated Volume Expansion-
Custom Docker Image
Authentication & Authorization
TLS: Add, Remove, Update, Rotate ( Cert Manager )
Reconfigurable Health Checker
Externally manageable Auth Secret
Pre-Configured JMX Exporter for Metrics
Monitoring with Prometheus & Grafana
Autoscaling (vertically, volume)
Custom Volume
Persistent Volume-
Connectors-

Lifecycle of Kafka Object

lifecycle

Lifecycle of ConnectCluster Object

lifecycle

Supported Kafka Versions

KubeDB supports The following Kafka versions. Supported version are applicable for Kraft mode or Zookeeper-less releases:

  • 3.5.2
  • 3.6.1
  • 3.7.2
  • 3.8.1
  • 3.9.0

The listed KafkaVersions are tested and provided as a part of the installation process (ie. catalog chart), but you are open to create your own KafkaVersion object with your custom Kafka image.

Supported KafkaConnector Versions

Connector PluginTypeVersionConnector Class
mongodb-1.13.1Source1.13.1com.mongodb.kafka.connect.MongoSourceConnector
mongodb-1.13.1Sink1.13.1com.mongodb.kafka.connect.MongoSinkConnector
mongodb-1.14.1Source1.14.1com.mongodb.kafka.connect.MongoSourceConnector
mongodb-1.14.1Sink1.14.1com.mongodb.kafka.connect.MongoSinkConnector
mysql-2.7.4.finalSource2.7.4.Finalio.debezium.connector.mysql.MySqlConnector
mysql-3.0.5.finalSource3.0.5.Finalio.debezium.connector.mysql.MySqlConnector
postgres-2.7.4.finalSource2.7.4.Finalio.debezium.connector.postgresql.PostgresConnector
postgres-3.0.5.finalSource3.0.5.Finalio.debezium.connector.postgresql.PostgresConnector
jdbc-2.6.1.finalSink2.6.1.Finalio.debezium.connector.jdbc.JdbcSinkConnector
jdbc-2.7.4.finalSink2.7.4.Finalio.debezium.connector.jdbc.JdbcSinkConnector
jdbc-3.0.5.finalSink3.0.5.Finalio.debezium.connector.jdbc.JdbcSinkConnector
s3-2.15.0Sink2.15.0io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector
gcs-0.13.0Sink0.13.0io.aiven.kafka.connect.gcs.GcsSinkConnector

User Guide