akkadotnet/Alpakka

Add debug logging to Kinesis Stages

Aaronontheweb opened this issue · 0 comments

In order to make it easier to debug connectivity issues with AWS Kinesis, we should add some debug logging in these areas:

_iterator = s.Response.NextShardIterator;
}
if (records.Count > 0)
{
foreach (var record in records)
_buffer.Enqueue(record);
_actor.Become(Ready);
_self.Tell(Pump.Instance);
}

Some pseudo code:

if(LogLevel.Debug.Enabled)
   Log.Debug("No messages found in Kinesis shard {0} retrying in {1} seconds", etc...);