connect-api

library4.2.0javamavenunverified

Kafka Connect API provides interfaces and classes for building Kafka Connect connectors to stream data between Kafka and other systems.

messaging

<dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>connect-api</artifactId>
  <version>4.2.0</version>
</dependency>

homepage ↗docs ↗

INSTALL

IMPORT

SIG · CONNECT-API

connect-api

messagingjavav4.2.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

Connector

✓ org.apache.kafka.connect.connector.Connector

Defines a minimal Kafka Connect connector by extending the Connector class.

import org.apache.kafka.connect.connector.Connector; import org.apache.kafka.connect.connector.Task; import java.util.List; import java.util.Map; public class MyConnector extends Connector { @Override public void start(Map<String, String> props) { } @Override public Class<? extends Task> taskClass() { return null; } @Override public List<Map<String, String>> taskConfigs(int maxTasks) { return null; } @Override public void stop() { } @Override public String version() { return "1.0"; } }

Debug

Known issues

breakingKafka Connect API versions must match the Kafka broker version to avoid compatibility issues.

fix

Use the same major version for connect-api as your Kafka cluster (e.g., 3.x for Kafka 3.x).

affects: all

Upgrade

Version history

4.2.0latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

43 hits · last 30 days

node

OpenAI (training)

Resources

homepagehttps://kafka.apache.org ↗

docshttps://appdoc.app/artifact/org.apache.kafka/connect-api/ ↗