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 <paul.joire...@physiq.com> wrote: > 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<String>(connectionConfig, "hello", new StringToByteSerializer())); > > However, a search of the flink github mirrored repo > <https://github.com/apache/flink> does not show where > StringToByteSerializer is defined and only shows it being used in the > documentation of > > this example. I've tried using a SimpleStringSchema which seems to > handle serialization but this raises an exception when I attempt to > > run it. > > > Does anyone have any experience with using a RabbitMQ sink? Any pointers > as to what I'm doing wrong. > > > Thanks, > > Paul > >