I had a customer recently ask me for something similar... My response was that there is nothing in Beam directly, but an existing message queue source (such as rabbitmq) could be copied and adapted to use ZeroMQ. The actual amount of code that would need to be modified is very little: the majority of the code is for configuration of the connector.
A non-serious over-engineered alternative would be ZMQ->Kafka->Beam... On Wed, 24 Jun 2020, 22:50 Luke Cwik, <[email protected]> wrote: > I'm not aware of any ZeroMQ connector implementations that are part of > Apache Beam. > > On Wed, Jun 24, 2020 at 11:44 AM Sherif A. Kozman < > [email protected]> wrote: > >> Hello, >> >> We were in the process of planning a deployment of exporting stream data >> from Aruba Networks Analytics engine through Apache beam and it turns out >> that it utilizes ZeroMQ for messaging. >> We couldn't find any ZeroMQ connectors and were wondering if it does >> exist or it would be compatible with other connectors for Apache Beam. >> >> Thanks >> Sherif Kozman >> >> <http://www.extremesolution.com> >> >> Sherif Kozman >> >> *Extreme Solution* >> >> A: 17875 Von Karman Ave suite 150, Irvine, CA, 92614 >> >> P: +1 714 719 2237 <+1-714-719-2237> M: +20 122 2426241 >> <+20-122-2426241> >> >> E: [email protected] W: www.extremesolution.com >> >> <https://twitter.com/extremesolution> >> >> <https://www.facebook.com/extremesolution/> >> >> <https://www.instagram.com/extremesolutionllc/> >> >> <https://www.linkedin.com/company/extreme-solution/> >> >> This email and any files transmitted with it are confidential and >> intended solely for the use of the individual or entity to whom they are >> addressed. If you have received this email in error please notify the >> system manager. This message contains confidential information and is >> intended only for the individual named. If you are not the named addressee >> you should not disseminate, distribute or copy this e-mail. Please notify >> the sender immediately by e-mail if you have received this e-mail by >> mistake and delete this e-mail from your system. If you are not the >> intended recipient you are notified that disclosing, copying, distributing >> or taking any action in reliance on the contents of this information is >> strictly prohibited. >> >> ↪ Schedule A Meeting With Me! >> <https://calendar.google.com/calendar/embed?src=sherif%40extremesolution.com&ctz=Africa%2FCairo> >> >> [image: >> https://s3.amazonaws.com/accredible_api_mails/embed_badge/12225976.png] >> <https://www.credential.net/r99bzgde> >> >> >>
