tp://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Wikiedit-QuickStart-with-Kinesis-tp8819p8840.html
Sent from the Apache Flink User Mailing List archive. mailing list archive
at Nabble.com.
n’t be a
problem decoding them (the FlinkKinesisConsumer uses a class from KCL to
help decode aggregated records sent by KPL).
Let me know if you bump into any other problems ;)
Regards,
Gordon
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Wik
r.
From: "Tzu-Li (Gordon) Tai"
Reply-To: "user@flink.apache.org"
Date: Thursday, September 1, 2016 at 2:25 AM
To: "user@flink.apache.org"
Subject: Re: Wikiedit QuickStart with Kinesis
Hi Craig,
I’ve just run a simple test on this and there should be no problem.
W
Hi Craig,
I’ve just run a simple test on this and there should be no problem.
What Flink version were you using (the archetype version used with the Flink
Quickstart Maven Archetype)?
Also, on which branch / commit was the Kinesis connector built? Seeing that
you’ve used the “AUTO”
credentials
Hi:
I am using the following WikiEdit example:
https://ci.apache.org/projects/flink/flink-docs-master/quickstart/run_example_quickstart.html
It works when printing the contents to a file or stdout.
But I wanted to modify it to use Kinesis instead of Kafka. So instead of the
Kafka part, I put:
P
