Wrap the DataSourceServer which exposes a write method and both the TCP Ingestion Server and the DataIngestion Router NettyHTTP Service can write to it directly.