KCL Protocol

Input/output

• consume from stdin
• control responses to stdout
• error output to stderr

Requests from Daemon

Initialize processor {"action":"initialize","shardId":"shardId-123"}

{"action":"processRecords","records":[{"data":"bWVvdw==","partitionKey":"cat","sequenceNumber":"456"}]}

{"action":"shutdown","reason":"TERMINATE"}

{"action":"shutdown","reason":"ZOMBIE"}