Hi Paul,
the example in the code is outdated, StringToByteSerializer has probably
been removed quite a while ago. I'll update the documentation once we
figured out the other problem you reported.
What's the exception you are getting?
Regards,
Robert
On Mon, Aug 8, 2016 at 4:33 PM, Paul Joireman
Hi all,
The documentation describing the use of RabbitMQ as a sink gives the following
example:
RMQConnectionConfig connectionConfig = new RMQConnectionConfig.Builder()
.setHost("localhost").setPort(5000).setUserName(..)
.setPassword(..).setVirtualHost("/").build();
stream.addSink(new RMQSink(
