Netty source
The Netty source connector opens a port that accepts incoming data via the configured network protocol and publish it to user-defined Pulsar topics
The Netty source connector opens a port that accepts incoming data via the configured network protocol and publish it to user-defined Pulsar topics.
This connector can be used in a containerized (for example, k8s) deployment. Otherwise, if the connector is running in process or thread mode, the instance may be conflicting on listening to ports.
Configuration
The configuration of the Netty source connector has the following properties.
Property
Name | Type | Required | Default | Description |
---|---|---|---|---|
type | String | true | tcp | The network protocol over which data is transmitted to netty. Below are the available options: |
host | String | true | 127.0.0.1 | The host name or address on which the source instance listen. |
port | int | true | 10999 | The port on which the source instance listen. |
numberOfThreads | int | true | 1 | The number of threads of Netty TCP server to accept incoming connections and handle the traffic of accepted connections. |
Example
Before using the Netty source connector, you need to create a configuration file through one of the following methods.
-
JSON
-
YAML
Usage
The following examples show how to use the Netty source connector with TCP and HTTP.
TCP
-
Start Pulsar standalone.
-
Create a configuration file netty-source-config.yaml.
-
Copy the configuration file netty-source-config.yaml to Pulsar server.
-
Download the Netty source connector.
-
Start the Netty source connector.
-
Consume data.
-
Open another terminal window to send data to the Netty source.
-
The following information appears on the consumer terminal window.
HTTP
-
Start Pulsar standalone.
-
Create a configuration file netty-source-config.yaml.
-
Copy the configuration file netty-source-config.yaml to Pulsar server.
-
Download the Netty source connector.
-
Start the Netty source connector.
-
Consume data.
-
Open another terminal window to send data to the Netty source.
-
The following information appears on the consumer terminal window.