shijinkui created FLINK-4630:

             Summary: add netty tcp source support
                 Key: FLINK-4630
             Project: Flink
          Issue Type: New Feature
          Components: Streaming Connectors
            Reporter: shijinkui

When source stream get start, listen a provided tcp port, receive stream data 
sent from the place where origin data generated.
This netty tcp source is end-to-end, that is from business system to flink 
worker directly. 

Such source service is needed in produce indeed.

describe the source in detail below:

1.      source run as a netty tcp server
2.      user provide a tcp port, if the port is in used, increace the port 
number between 1024 to 65535
3.      callback the provided url to report the real port to listen

This message was sent by Atlassian JIRA

Reply via email to