Jeroen, Did you build RabbitMqIO 2.9.0-SNAPSHOT yourself or get it from a repository?
If you got it from a repo which one? Cheers, Stuart Schmukler ZOOM: https://rakuten.zoom.us/j/9516474263 From: Jeroen Steggink | knowsy <[email protected]> Organization: knowsy Reply-To: "[email protected]" <[email protected]> Date: Tuesday, December 11, 2018 at 2:44 AM To: "[email protected]" <[email protected]> Subject: Re: Getting the 2.9.0 SNAPSHOT to test RabbitMq? Hi, We are experiencing the same thing. I tried RabbitMqIO 2.9.0-SNAPSHOT and deployed on Flink 1.5.5. The problems: - RabbitMQ advices to share connections and have different channels. I don't think that's possible with Beam when having both a Read and a Write RabbitMqIO? - Flink job finishes without any error. I can't seem to figure out why. All the messages are consumed, but not acknowledged. - When I have a withQueueDeclare in the pipeline it only works the first time. The second time I get a RabbitMq connection error and the pipeline is restarted over and over again. I tried making my own RabbitMq with the newer RabbitMq client, which is asynchronous, but can't seem to make that work either. All my other Java applications using the same RabbitMq client seem to be working fine. Is it a threading issue maybe? Cheers, Jeroen On 10-Dec-18 21:43, Schmukler, Stuart wrote: Folks, We have been trying to use RabbitMq with Beam via the RabbitIO transformer(?). There have been problems connecting. I’ll like to see if the RabbitIO 2.9.0 will work in our use case. Make it a great day, Stuart Schmukler ZOOM: https://rakuten.zoom.us/j/9516474263
