[GitHub] erenavsarogullari opened a new pull request #3095: [Pulsar-Netty] Add Netty Connector Support for Tcp Messages

[GitBox <gi...@apache.org>]

erenavsarogullari opened a new pull request #3095: [Pulsar-Netty] Add Netty Connector Support for Tcp Messages
URL: https://github.com/apache/pulsar/pull/3095
 
 
   ### Motivation
   Netty is NIO client server framework by supporting asynchronous event-driven communication and custom protocol implementation.
   **Ref:** https://netty.io/ 
   
   This PR proposes `Pulsar-Netty` Connector by helping the Tcp clients. It enables an embedded Tcp Server to listen incoming Tcp messages and writes them to Pulsar by behaving as Pulsar Source.
   
   There are also other potential use-cases for this connector as follows:
   - `Tcp Client` (Pulsar Sink): It can listen Pulsar messages and can write remote Tcp Server.
   - `Http Server` and `Client` (Pulsar Source and Sink)
   - `Udp Server` and `Client` (Pulsar Source and Sink)
   - Also Pulsar functions can be applied incoming Tcp, Http and Udp messages through related topics.
   
   ### Modifications
   1- `PulsarTcpServer`: Initializes an embedded Tcp Server to listen incoming Tcp Requests
   2- `PulsarTcpServerHandler`: Inbound Channel Handler to handle incoming Tcp Requests
   3- `PulsarChannelInitializer`: Pulsar Channel Initializer to support different types of decoders and handlers
   4- `PulsarSerializer`: Pulsar Generic Serializer Interface to serialize generic typed objects to byte-array
   5- `PulsarStringSerializer`: String Implementation of Generic Serializer Interface as user-ready
   6- `PulsarUtils`: Initializes and services singleton Pulsar Producer
   7- UT Coverage
   8- `Examples`: Covers both String and Pojo based message examples
   9- `README.md`

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services