The Netty Source connector opens a port that accept incoming data via the configured network protocol and publish it to a user-defined Pulsar topic. Also, this connector is suggested to be used in a containerized (e.g. k8s) deployment. Otherwise, if the connector is running in process or thread mode, the instances may be conflicting on listening to ports.
Source Configuration Options
|The network protocol over which data is trasmitted to netty. Valid values include HTTP, TCP, and UDP|
|The host name or address that the source instance to listen on.|
|The port that the source instance to listen on.|
|The number of threads of Netty Tcp Server to accept incoming connections and handle the traffic of the accepted connections.|