《中邮消费金融》专题

我看了Kafka的文件，还不知道如何消费一个话题平行？ 假设：我有一个像“发生了一些事情”这样的话题（不要拆分这个话题），我有很多想消费它的客户。那么该怎么办，让多个客户并行消费呢？我应该使用分区和客户群吗？

我们有一个问题，似乎Kafka消费者没有收到发布到某个主题的消息。（我说这是因为我还没有弄清楚这件事的真相，我可能错了。） 我使用Spring for Apache Kafka，而我的消费者实际上是一个用注释的方法。 这个问题是断断续续的，我很难重新创建它。 有没有一种方法让我看看Kafka经纪人的日志，或任何其他工具，以帮助我找出抵消为我的消费者？我想要具体的证据来证明我的消费者是否收到了信息。

请有人向我解释一下这两种方法的区别： 以及：

Spring cloud stream starter kafka在连接消费者时没有加载配置。以下是我在调试模式下运行控制台时在控制台中看到的配置： 我有以下引导yml文件的配置部分

我开发了一个基于Java的Kafka消费者，其中每个消费者实例有100个线程，当消费过程开始时，每个线程都得到一个分区（因为有100个分区），然后消费就完成了。 但这里的问题是这只是一个消费者。但是如果我添加多个nodejs进程，我可以完成100个消费者，但是添加每个消费者是一个成本很高的再平衡操作。 我想知道这是否正确的做法？有没有一种方法可以使用Kafka节点触发一个100线程的消费者？

我使用MQTT消费者作为我的flink作业的数据源。我想知道如何将数据偏移保存到检查点中，以确保flink集群在故障后重新启动时不会丢失数据。我看过很多介绍apache flink如何管理kafka消费者补偿的文章。有人知道apache flink是否有自己的功能来管理MQTT使用者吗？谢谢

我克隆了SCDF Kinesis示例：https://github.com/spring-cloud/spring-cloud-dataflow-samples/tree/master/dataflow-website/recipes/kinesisdemo并运行相同的示例。kinesis生产者正在运行并将事件发布到kinesis。但是，由于以下错误，Kinesis消费者Spring启动失败。请让

配置类： 消费阶层：

目前，我正在查看Liferay及其portlet功能，尤其是通过WSRP的远程portlet。 我有两个liferay实例在同一网络中的不同机器上运行。现在我想将一个portlet从一个liferay实例共享到另一个实例，因此我在两个安装上都安装了WSRP应用程序，并将其中一个节点配置为WSRP生产者，另一个节点配置为WSRP消费者。我的WSRP制作人发布了包含在Liferay中的用于货币计算的p

我已经用MassTransit实现了一个简单的发布者/使用者集，我想让使用者从同一个队列中读取消息。但是，当我运行它时，我看到很大一部分消息被发送到错误队列，而不是被消耗。从我看到的讨论（所以，论坛）来看，对于RabbitMQ来说，这应该非常非常简单（只需指向相同的队列），但它并不起作用。是否有应该设置的附加配置？ 这是我的出版商 还有我的消费者

你们中有人知道用SOAP web服务实现消费者驱动的契约的方法或工具吗？我有一个发布SOAP web服务的遗留Java应用程序，用Apache CXF实现，由一群Spring Boot Java微服务使用。我已经在使用Pact和Spring Cloud Contract来测试我在微服务之间的REST调用，但是找不到一种方法来使用这些相同的工具或任何其他工具来实现SOAP web服务。

我刚刚开始研究使用hdfs接收器向hdfs写入消息的水槽。我想知道水槽源是否可以充当我的消息代理的jms消费者。 flume是否提供与消息代理的集成。或者我是否需要编写一个自定义jms客户端，将消息推送到水槽源。

我是Kafka的新手，我已经在3台服务器上实现了KAFKA集群，并且在3台服务器中运行消费者，每台服务器有3个消费者，即…3x3=9个消费者。 我的问题是：-1.当我为同一主题在整个集群中提供相同的组ID时，我没有收到任何重复消息，但当我为相同主题在集群中提供3个不同的消费者组ID时我收到的重复消息正好是3？ 请帮忙如何利用消费群体？

我是Kafka的新手，我将非常感谢关于下一个案件的澄清。 Kafka文档在“消费者立场”一段中说： 问题是，如果只有一个消费者能够拉出特定的信息，那么如何向多个消费者群体广播呢？

我正试图和一个朋友一起通过谷歌游戏控制台做一些内部测试。我已经安装了我的应用程序，并按照他们网页上列出的步骤操作，成功上传了一个构建。 虽然我已经注意到，一旦我按下上传，版本号就被消耗了。天气防护我保存或丢弃释放。我认为即使如此，如果apk有错误！如果我不小心犯了一个错误，这是非常烦人的，因为我必须等待编辑器用新版本号再次为我构建另一个32和64位的apk！ 为什么会发生这种情况？有什么方法可以手