水槽源可以充当jms消费者吗
我刚刚开始研究使用hdfs接收器向hdfs写入消息的水槽。我想知道水槽源是否可以充当我的消息代理的jms消费者。
flume是否提供与消息代理的集成。或者我是否需要编写一个自定义jms客户端，将消息推送到水槽源。
共有1个答案
Flume 1.3不提供现成的JMS源。然而，此类组件似乎将随下一版本Flume 1.4一起发货：https://issues.apache.org/jira/browse/FLUME-924.
同时，您可以在此处获取此新组件的源代码并构建它。AFAIK，Flume 1.4 不会破坏其接口，因此该组件可能也适用于 1.3。
-
问题内容： 我有一个JMS客户端，它正在生成消息并通过JMS队列发送到其唯一的使用者。 我想要的是不止一个消费者收到这些消息。我想到的第一件事是将队列转换为主题，以便现有用户和新用户都可以订阅并将相同的消息传递给他们。 显然，这将涉及在生产者和消费者方面修改当前的客户代码。 我还要查看其他选项，例如创建第二个队列，这样就不必修改现有的使用者。我相信这种方法有很多优点，例如（如果我错了，请纠正我）在
-
我有一个从JMS队列读取项目并将其写入数据库的路径。 我已经阅读了关于ApacheCamelJMS组件的文档，但我没有得到我的问题的确切和明确的答案，即“如果路由中出现异常，JMS消费者是否会重新插入项目或解锁JMS队列中的消息？”。 谢谢 阿里
-
我有一个多分区主题，由多个使用者（同一组）使用。我的目标是最大化消费处理，即任何消费者都可以消费来自任何分区的消息。 我知道这看起来是不可能的，因为只有一个消费者可以从一个分区中消费。 有没有可能使用REST代理来实现这一点？例如，轮询所有代理消费者实例。 谢了。
-
我想使用 flume 将数据从 hdfs 目录传输到 hdfs 中的目录，在此传输中，我想应用处理形态线。 例如：我的来源是 我的水槽是 有水槽可能吗？ 如果是，源水槽的类型是什么？
-
我已经用Apache ActiveMQ和一个简单的应用程序创建了一个JMS代理，该应用程序将消息纳入队列OK。 我想创建另一个简单的应用程序，使用MDP异步出列这些消息。以下是我到目前为止所拥有的一个例子： 现在我大概需要一个main方法，但是如果消息到达队列时监听器会异步调用onMessage方法，我不确定如何编写代码： 谢谢你的帮助。
-
本文向大家介绍Kafka 消费者是否可以消费指定分区消息？相关面试题，主要包含被问及Kafka 消费者是否可以消费指定分区消息？时的应答技巧和注意事项，需要的朋友参考一下 Kafa consumer消费消息时，向broker发出fetch请求去消费特定分区的消息，consumer指定消息在日志中的偏移量（offset），就可以消费从这个位置开始的消息，customer拥有了offset的控制权，可