Hi! We have a SocketSourceFunction in the flink-examples-table module. Note that this is only an example and cannot be used in production. See its java doc for more information. If you want a production-ready socket source you can modify that and implement your own.
Robert Cullen <cinquate...@gmail.com> 于2021年11月19日周五 上午12:02写道： > Does flink have a connector for TCP/IP messages? > > -- > Robert Cullen > 240-475-4490 >
