Generic

Generic Kafka Connection

The connection is formed based on supplied connection properties.

Settings

Name Type Description

Name	Type	Description
Bootstrap Nodes	string or list	A list of servers to establish the initial connection to the Kafka cluster. The following formats are accepted: A string in `host1:port1,host2:port2,...` format A list of strings where each entry is in `host:port` format A list of dicts where each entry is a dict of the form `{:host string, :port string}` This setting is used to fill the bootstrap.servers configuration property.
Properties	dict or list	Additional connection properties to use. See Kafka Configuration documentation for details. If you supply a dict, the keys and values are interpreded as property names and values. If you supply a list, each item must be of the form: `{:name string, :value string}`.

string or list

A list of servers to establish the initial connection to the Kafka cluster.

The following formats are accepted:

A string in host1:port1,host2:port2,... format
A list of strings where each entry is in host:port format
A list of dicts where each entry is a dict of the form {:host string, :port string}

This setting is used to fill the bootstrap.servers configuration property.

dict or list

Additional connection properties to use.

See Kafka Configuration documentation for details.

If you supply a dict, the keys and values are interpreded as property names and values.

If you supply a list, each item must be of the form: {:name string, :value string}.

You can test the connection from the context menu.