Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5069
@bowenli86 do you mean the `ProduceIntoKinesis` and `ConsumeFromKinesis`
classes?
I agree that we should move them to `/test`, but we should consider that as
a separate issue than this one. Could you open a JIRA for that?---
