Configuration

NettySourceConnector

The Source Connector will receive data from network and write to kafka a topic.

name=nettyConnector
tasks.max=1
connector.class=com.mckesson.kafka.connect.nettysource.NettySourceConnector
topic=network_data

# Set these required values
transport.protocol=TCP
port=1234

Name	De scription	Type	Default	I mportance	Notes
bin d.address	Bind address	string	0.0.0.0	high
transport .protocol	Transport level protocol	string	tcp	high	allowed values: tcp, udp
port	Listening port	int		high
pipe line.fact ory.class	Class name imp lementing org .jboss.ne tty.chann el.Channe lPipeline Factory	class	depends on protocol	high	for tcp: com. mckesson. kafka.con nect.nett ysource.D efaultTcp PipelineF actory, for udp: com. mckesson. kafka.con nect.nett ysource.D efaultUdp PipelineF actory. See below conf iguration options for the factories
ports	Listening ports	list		medium	same as ‘ port’ but multiply ports can be s pecified, used if port is already in use
h ealthchec k.enabled	Enable he althcheck listener	boolean	false	medium	Enable listening tcp port for he althcheck purpose. Useful when transp ort.proto col=udp and loa dbalancer c onfigured in front of kafka connect.
health check.bin d.address	Bind address for he althcheck	string	0.0.0.0	medium
healthc heck.port	Listening port for he althcheck	int		medium
healthch eck.ports	Listening ports for he althcheck	list		medium	same as ‘ port’ but multiply ports can be s pecified. used if port is already in use
ss l.enabled	Enable SSL/TLS	boolean	false	medium	can be used for transp ort.proto col=tcp only. See below for the available options

SSL configuration options

Name	D escription	Type	Default	Importance	Notes
ss l.protocol	The SSL protocol used to generate the S SLContext.	string	TLS
ssl.key store.type
s sl.keystor e.location
s sl.keystor e.password
ssl .key.alias	key alias for JKS	string
ssl.ke y.password
ssl.trust store.type
ssl .truststor e.location
ssl .truststor e.password

see org.apache.kafka.common.config.SslConfigs for more comprehensive description of above params

PipelineFactory configuration options

Name