Stage Logic and Actor logging with ID

[seglo]

Purpose

Prefix each Akka Stream graph stage logic and KafkaConsumerActor log statement with a 5 character UID to make it easier to troubleshoot logging when multiple streams or partitioned sources are being used.

References

• Issue: Add short uid prefix to logging for consumer and producer stages #990

Changes

• Update all stage logics with StageIdLogging
• Update KafkaConsumerActor with ActorIdLogging

Background Context

I used something like this to troubleshoot problems with partitioned sources and the transactional partitioned source PRs (#930)

[ennru]

Great implementation for this cross-cutting concern.
LGTM.

[seglo]

Thanks!