Extract SocketServer and start implementing KafkaServer for agent

spirit-labs / tektite

Tektite DB

http://www.tektitedb.com

Other

167 stars 25 forks source link

Closed purplefox closed 5 days ago

purplefox commented 1 week ago

This PR:

Extracts a SocketServer which knows how to handle length delimited messages from the SocketTransport into its own package
Base SocketTransport on the new SocketServer
Start implementing a new KafkaServer based on the SocketServer that will be used by the new Agent.
Moves kafka protocol generated structs into the kafkaprotocol package