Github user fbeneventi commented on the issue:
https://github.com/apache/bahir/pull/37
@ckadner -- I wiil test the anntinutj PR in the next days, but I need to
repalce this in my current setup. I'm just using my own modified version of the
MQTT-connector that does quite the same of anntinutj but, however, it doesn't
support multi-topic input and so it wastes resources allocating multiple MQTT
receivers, one for each supplementary topic that has a different pattern (i.e.
cannot be inserted with wildcards).
The anntinutj PR is very important because:
- preserves resources in the Spark clusters
- gives the opportunity to filter topics, an thus to efficiently manage
payloads, inside the Spark programs.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
