《中邮消费金融有限公司》专题

我在kafka消费者文档中看到了这个注释-

我的主要问题是：在JPA实体类内的方法上，除了@Consumed注释之外，还有其他选择吗？ 我问这个问题是因为我真的想把我的JPA模型（例如我的所有实体）具体化，以便能够在使用相同数据库的其他项目之间共享。此外，我不想在我的子项目中出现一些骆驼依赖，这意味着要删除@Consumed注释。我基本上有这样一条路线： 我尝试了不同的解决方案： 在我的camel项目中，使用@Consumed方法扩展子模块

我正在使用Spring Kafka消费者。我已将并发设置为10，并创建了5个消费者（用于5个主题）。所以有50个Spring Kafka消费者线程。 Kafka消费者可以使用的最大线程数是多少？如何增加此线程池的大小？我查阅了spring文档，但没有发现任何相关内容。

我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？ 或者，在使用

我想在远程位置检查Kafka消费者的连接。 可以确定是否将使用者分配给分区。 在远程位置，我可以从Kafka代理获得有关该主题的详细信息。 但是消费者能否保证消费者能够收到消费者与主题分区匹配的消息？

我正在建立一个新的Kafka集群，为了测试目的，我创建了一个有1个分区和3个副本的主题。 有什么想法哪种配置或其他东西可以帮助我消费更多的数据吗？？ 提前致谢

我有一个从JMS队列读取项目并将其写入数据库的路径。 我已经阅读了关于ApacheCamelJMS组件的文档，但我没有得到我的问题的确切和明确的答案，即“如果路由中出现异常，JMS消费者是否会重新插入项目或解锁JMS队列中的消息？”。 谢谢 阿里

我是Guice的新手，正在为以下用例寻求帮助: 我开发了一个软件包（PCKG），其中该软件包的入门级依赖于其他类，例如： 在我的绑定模块中，我正在做： 注意我没有为A提供绑定信息，因为我想通过它的消费者类来提供它的绑定。(设计就是这样，所以我的要求是继续讨论主要问题，而不是设计)。 现在，我的消费者阶层正在做这样的事情: 同样在我的消费者包装中： Q1。我在消费者类中做的绑定正确吗？我很困惑，因为

关于KafkaConsumer(>=0.9)，我在尝试实现满足自己需求的解决方案时遇到了一些严重的问题。 假设我有一个函数，它只能从一个Kafka主题中读取n条消息。 例如:-->获取主题中的下5条kafka消息。 所以，我有一个类似这样的循环。用实际正确的参数编辑。在本例中，使用者的max参数设置为1，因此实际循环只循环一次。不同的消费者（他们中的一些人迭代了许多消息）共享一个抽象的父亲（这一个

我对骆驼生产商有很好的了解，但我不能对各种骆驼消费者保持清醒的头脑。特别是事件驱动消费者和轮询消费者，camel如何知道为这些消费者调用回调？ 消费者的一般流量是多少？

我只是在试用这里提到的kafka-storm喷口https://github.com/nathanmarz/storm-contrib/tree/master/storm-kafka，我使用的配置如下所述。 但是，上面的喷子从Kafka主题中获取消息的速度大约是每秒7000条，但我预计每秒大约有50000条消息。我尝试了在spoutConfig中增加提取缓冲区大小的各种选项，但没有看到任何结果。

我正试图按照GitHub的建议设置测试 其中StreamProcessor设置为 -->line从不使用在我看来应该在主题“output”上的消息，因为@StreamProcessor有@Sendto（“output”） 我希望能够测试流处理的消息。

我有一个Kafka主题，并为其附加了1个消费者(主题只有1个分区)。现在对于超时，我使用默认值(心跳:3秒，会话超时:10秒，轮询超时:5分钟)。 根据留档，轮询超时定义消费者必须在其他代理将该消费者从消费者组中删除之前处理消息。现在假设，消费者只需1分钟即可完成处理消息。 现在我有两个问题

我最近开始学习Kafka，最后就问了这些问题。 > 消费者和流的区别是什么？对我来说，如果任何工具/应用程序消费来自Kafka的消息，那么它就是Kafka世界中的消费者。 流与Kafka有何不同？为什么需要它，因为我们可以使用消费者API编写自己的消费者应用程序，并根据需要处理它们，或者将它们从消费者应用程序发送到Spark？ 我做了谷歌对此，但没有得到任何好的答案。抱歉，如果这个问题太琐碎了。

Kafka在2个代理和1个Zookeeper实例中的奇怪问题，都在AWS上。每个代理都位于一个单独的可用性区域(AZ)。孤独的动物园管理员实例与其中一个代理共享AZ。我正试图模拟一种滚动重启的情况，在这种情况下，即使一个代理出现故障，我们也希望数据流向Kafka。 当另一个 AZ 代理被移除时，我能够看到向与 Zookeeper 共享 AZ 的代理平稳过渡。但是，当我删除与 Zookeeper 共