Add counters in KafkaSink and MessageProcessor

[metacret]

For debugging purpose, we need to add queuedRecordCount in KafkaSink and routedMessageCount in MessageRouter.