Problem Sinking from Scala Stream Collector to Kinesis

For engineers Collectors
1

Hi, when I test the Python tracker, I got the following debug message:

07:13:20.854 [scala-stream-collector-akka.actor.default-dispatcher-2] DEBUG s.can.server.HttpServerConnection - Connection was PeerClosed, awaiting TcpConnection termination...
07:13:20.858 [scala-stream-collector-akka.actor.default-dispatcher-2] DEBUG s.can.server.HttpServerConnection - TcpConnection terminated, stopping

Please advise.

2

Hi @lam - those are just debug messages. What’s the exact problem you are seeing?

3

Thanks, Alex.

There’s no problem actually. I was looking at monitoring dashboard in Kinesis, but it was showing no data was put through. However, I deleted and recreated the stream this morning and it starts to work.

Apologies for the nonsense.

4

I had a similar problem a few days ago but with Enrich and the S3 sink. Cloudwatch was telling me the records were going in but the S3 sink wasn’t pulling any records and recreating the streams fixed the problem.

Bit worried I couldn’t explain why it happened.