Add debug logging to Kinesis Stages
Aaronontheweb opened this issue · 0 comments
Aaronontheweb commented
In order to make it easier to debug connectivity issues with AWS Kinesis, we should add some debug logging in these areas:
Alpakka/src/AWS/Kinesis/Akka.Streams.Kinesis/KinesisSourceStage.cs
Lines 158 to 168 in c0ba451
Some pseudo code:
if(LogLevel.Debug.Enabled)
Log.Debug("No messages found in Kinesis shard {0} retrying in {1} seconds", etc...);