Connector implementor can use this annotation to document attributes supported by their connector. This allows tools
(IDE, annotation processors...) to extract that data to provide code completion or documentation generation.
Each attribute is represented by an instance of
ConnectorAttribute
. For example:
@ConnectorAttribute(name = "bootstrap.servers", alias = "kafka.bootstrap.servers", type = "string",
defaultValue = "localhost:9092", direction = Direction.INCOMING_AND_OUTGOING,
description = "...")
@ConnectorAttribute(name = "topic", type = "string", direction = Direction.INCOMING_AND_OUTGOING,
description = "...")
@ConnectorAttribute(name = "value-deserialization-failure-handler", type = "string", direction = Direction.INCOMING,
description = "...")
@ConnectorAttribute(name = "merge", direction = OUTGOING, type = "boolean", defaultValue = "false",
description = "...")
@Connector("my-connector")
public class MyConnector implements IncomingConnectorFactory, OutgoingConnectorFactory {
...
}