我们有一个flink流应用程序，从卡夫卡读取消息。由于某些原因，我们不得不从kafka重置命令将kafka偏移重置为最新，因为有大量堆积。我们希望flink应用程序跳过所有这些消息，并从重置后出现的新消息开始。问题是因为flink在内部管理它的偏移量，它不知道这个重置，它现在只从后向读取msg (重置前的偏移点)，现在也不能提交偏移量。因此，每次重启flink应用程序时，它都会再次从同一点读取。我知道我们不应该在flink kafka应用中手动重置偏移量。但是我们怎样才
浏览 62提问于2021-06-19得票数 4
回答已采纳
0回答
HornetQ持久性未删除文件
、、、、
在我的应用程序中，我注意到HornetQ 2.4.1已经堆积了大量的消息日志文件(有时多达数千个)。我通过JMS队列使用HornetQ，我们使用Wildfly8.2。通常，在启动服务器实例时，HornetQ会有3个消息日志和一个锁文件。消息日志文件堆积导致重新启动服务器时出现问题，我们将看到以下日志：删除文件时，服务器加载正常。我已经尝试了一些，似乎这些文件中的消息已经被处理过了，但我不确定为什么随着时间的推移，它们会继续堆积
浏览 4提问于2017-12-12得票数 6
回答已采纳
每行都是一条jms消息。所以我总共会发布300万条消息。JMS Queue是否支持队列中如此多的大型数据？
浏览 1提问于2016-03-07得票数 0
卡夫卡中的demo.incoming话题堆积如山。截图中显示了该主题的分区数为8。理论上，Kafka的消息数量应该保持在非常低的数量。因为消费者，在这种情况下是Kafka-mo
浏览 1提问于2019-07-07得票数 1
我们有大量的发布-订阅消息流。但我们有时会看到消息在队列管理器中的SYSTEM.INTER.QMGR.PUBS中堆积起来，其中定义了主题和订阅，为了再次获得消息流，我们必须重新启动队列管理器。我读过的很少，比如如果目标订阅队列上没有消费者，消息可能会堆积在这个系统队列中。但是在我们的例子中，当我们看到这个积压时，所有的集群传输和其他订阅队列都是空的。有没有人看到类似的行为？
浏览 1提问于2016-03-12得票数 1
1回答
首先，请参考这段代码： lt = time(NULL); strftime(str, 100, "%c", ptr);
temp = spri
浏览 0提问于2012-10-22得票数 2
出于故障排除的目的，我希望获得将消息发送到特定队列或交换的生产者的列表。我在rabbitmq控制台中看不到任何获取上述详细信息的选项。一些生产者正在堆积一个零散的队列，我正在尝试找出生产者在队列中堆积消息的IP。
有人能在这方面给我指点一下吗？
浏览 0提问于2018-11-02得票数 0
1回答
我需要使用c++在win32应用程序中使用简单的矩形绘制仪表。在窗口中绘制仪表的最佳方法是什么(应该每10ms重新绘制一次)？我应该直接将其绘制到窗口中(在message WM_PAINT上)，还是使用其他组件并绘制到窗口中？
浏览 1提问于2011-09-20得票数 0
回答已采纳
在web应用程序中，我们订阅了一个主题并使用了消息平面缓冲(大约700kb)。为了测试，在使用之后，我们只打印"message recieved“。我们似乎不能更快地消费，消息堆积如山。Hello World“我们可以消费一切，不会堆积。因此，当消息大小较大时，似乎存在消耗缓慢的问题。
有什么想法或建议来处理这个问题吗？我们使用的是Solace JS API网站上提供的示例。
浏览 0提问于2017-07-29得票数 0
1回答
WPF -同步UI更新
、、、
pbProgress.Value = pbProgress.Maximum * e.Percent;}
最终显示完整的进度条和消息
浏览 3提问于2011-07-27得票数 2
2回答
我正在和一个外部设备(PLC)通信，他要求数据。我想改变我的代码，它将一个一个地处理它们。有时候他似乎同时处理了其中的两个。(可能因为其中一个比另一个要花更长的时间来完成)我读过一些关于异步方法和等待/任务等方面的内容，但是对于这么简单的事情来说，这似乎是一项很大的工作。private void PLCValueChanged(object sender, EventArgs e) bool xDispla
浏览 4提问于2022-07-25得票数 1
为什么处理已填充和持久的JMS队列(大约50.000条消息)比处理较少的已填充和持久的JMS队列要慢？这里有谁能回答我的问题吗？:)
非常感谢！
浏览 2提问于2012-01-24得票数 0
我想在python中构建一个客户机/服务器应用程序，其中：
问题是:是否有办法只接收最后的包裹，即忽略之前发送的包裹？服务器端：import multiprocessingimport time
address
浏览 1提问于2018-03-13得票数 0
我注意到，在高活动期间，工作进程的内存使用量有时会激增(虽然这不是泄漏，因为它会重新关闭，而且这是一个没有垃圾回收的C程序)，这让我相信，当工作进程对所有备份记录的消息进行排序时，zmq拉入套接字队列会被填满消息是否也在推送套接字中排队，或者它们是否已丢失？
浏览 4提问于2018-01-31得票数 0
2回答
如果用户身份验证失败，我会向用户闪现一条消息，让他们知道。但是，如果用户继续提供错误的凭据，这些闪存消息会不断堆积。有没有办法在发布新的消息之前先清除闪现的消息？
浏览 2提问于2010-01-07得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
