突然间，Kafka Streams（scala）应用程序陷入了重新加入的过程（没有明显的原因），并且从未完成它。
我正在摆弄K8s处理的Kafka Streams。到目前为止，它或多或少进展顺利，但在测试环境中观察到奇怪的行为：
[消费者clientId=dbe-livestream-kafka-streams-77185a88-71a7-40cd-8774-aeecc04054e1-StreamThread-1-Consumer，groupId=dbe-livestream-kafka流]我们收到了一个任务[_livestream.dbe.tradingcore.sporteventmapping-table-0，_livestream.dbe.tradingcore.sportventmapping-table-2，_livestream.dbe.Tradingcores.porteventmapping s-table-4，_livestrum.dbe.ttradingcore.sportEventmapping-table-6，livestream.dbe.tennis.results-table-0，livestream.debe.tennis-results-table-2，livestream-dbe.tennist.results-table-4，livestream-debe.tenniss-results-table-6，_livestradingcore.dbe.thenis-results.tennis-results table.bet管理员。sportseventmappings-table-0，_livestrem.dbe.betmanager。运动事件映射表-2，_livestrem.be.betmanager。运动事件映射表-4，_livestrem.be.betmanager。sportseventmappings-table-6]，与我们当前的订阅不匹配订阅（_livestream.dbe.betmanager sportseventMappings table | _livestream.dbe.trading_states | _livestrem.dbe.trading core.sporteventmappings table | livestream.dbe.netneting.markets | livestream.debe.netnish.markets table）；自从我们加入该组以来，订阅很可能发生了变化。将尝试使用当前订阅重新加入组
据我所知，内部状态不知何故被破坏了，Stream的真相来源与经纪人/动物园管理员的真相来源相冲突。这种行为永远不会终止：我只是因为忙于另一件事而让它挂了几天，但它仍然是在WARN级别报告的。更重要的是：这次没有报告ERROR。
我什么也没有改变；未部署新实例；没有以任何可能影响上述Kafka Streams应用程序的方式操纵Kafka经纪人。知道怎么了吗？
共有1个答案
错误消息本身表明您的订阅有问题。如果您有两个 Kafka Streams 实例使用相同的 application.id，但两者都没有订阅确切的某些主题，则可能会发生这种情况。
在您的情况下，订阅不包含livestream.dbe.tennis.results-table，但会分配相应的分区。
请注意，Kafka Streams要求具有相同< code>application.id的所有实例都必须执行exact some 拓扑，从而订阅exact some主题。
-
问题内容： 大家好，我有一个Java问题。对于我的高级研究班，我已经差不多完成了，但是我只需要分析生成的图像中的一些数据即可。我不想将其标记为家庭作业，因为它不是任何必需任务的一部分……这是我自己想出的结果。我编写了一个程序，可以逐像素比较两个图像。它对两个目录中的所有.bmp文件执行此操作。现在，我的程序将文件名读取到String数组中，并检查了所有文件名的值，因此我知道最初可以很好地访问目录和
-
TL；从一个活动切换到另一个活动并返回后，当我点击工具栏中的导航图标时，DR My app会最小化（就像按下了home按钮一样）。 行动的详细流程： 打开应用程序，活动1出现 我知道这个应用程序被最小化了，因为当我打开它时，Activity1在屏幕上有一个打开的抽屉 没有异常或日志（级别为Verbose），这只发生在OnePlus 2上（该应用程序在Nexus 4上运行良好）
-
问题内容： 这是我正在使用的Golang程序，目的只是为了使我的概念正确。当我运行程序时，它陷入了僵局，我不明白为什么？请任何人指出出了什么问题？ 输出为： 问题答案： 问题是您要将传递给goroutines 的副本，而不是引用（即指针）： 另外，由于是全局变量，您可以完全删除该参数：
-
我们在Azure应用程序服务计划中遇到CPU峰值，没有明显的原因。这并不是停止服务的原因，但我们想知道什么时候 例如，CPU百分比连续几天保持在0-1%的范围内，但突然它飙升到98%, 45%, 60%并很快回到0-1%的范围内。内存保持在舒适的40-45%水平不变，没有传入请求，没有Web作业，日志中没有异常，没有故障，服务健康正常，没有我们可以指出的原因。我们试图通过kudu找到答案 该应用程
-
应用程序昨晚运行时正在编译。今天早上它抛出了这个错误：
-
我已经成功地预先在另一个项目中添加了一个新的主要活动。然而，我试图在不同的项目中使用相同的技术（由于主线程中的工作量而出现问题）。 我想创建一个名为“主页”的简单主页，上面有一个按钮，可以弹出名为“主活动”的原始主活动。"主要活动用于连接到名为"GetLightData"的servlet。这个项目在添加主页之前在模拟器上工作（有一些错误），但是现在它会立即崩溃。我真的很感激特定于我的代码的答案，谢