consumer 相关问题

RabbitMQ 批量消费消息并一次全部确认

我有一个 RabbitMQ 队列，我在其中发布了数千条消息。我需要一个后台服务来： 批量检索消息，每组消息 100 条 将这 100 条消息存储在数据库中 确认...

SpringJMS - 如何优雅地关闭 DefaultMessageListenerContainer 以便所有消费者都被停止/杀死

DefaultMessageListenerContainer.shutdown 或 DefaultMessageListenerContainer.destroy 不会从队列中删除使用者。 这是类似的帖子：SpringJMS - 如何断开连接

在 Flutter 中调用 notificationListner() 后消费者无法更新

我有一个带有 ChangeNotifer 的课程。当我调用此类中的方法时，我希望更新列表视图。 这是课程： 带有 ChangeNotifier 的 WorkoutProvider 类 { 列表 我有一堂课是 with ChangeNotifer。当我调用此类中的方法时，我希望更新列表视图。 这是课程： class WorkoutProvider with ChangeNotifier { List<Exercise> _workoutList = <Exercise>[]; ///constructor WorkoutProvider(); ///get&set List<Exercise> get workout => _workoutList; set workout(List<Exercise> value) { _workoutList = value; } ///removing an exercise to the list void removeExercise(Exercise exercise) { _workoutList.remove(exercise); print("deleting"); notifyListeners(); } } 这是列表视图： myPro = Provider.of<WorkoutProvider>(context); body:Consumer<WorkoutProvider>( builder: (BuildContext context, WorkoutProvider value, Widget? child) { print("building cons"); return ListView.builder( padding: EdgeInsets.symmetric(horizontal: 30, vertical: 10), itemCount: value.workout.length, itemBuilder: (context, index) => Container( margin: EdgeInsets.symmetric(vertical: 3), child: exerciseCard(value.workout.elementAt(index))), ); }, ), /// used to delete the exercise from the list of exercises Widget buildDeleteExerciseBt(Exercise delExercise) { return IconButton( onPressed: (){ myPro.removeExercise(delExercise); }, icon: Icon( Icons.delete, color: Colors.red, )); } 检查后，它正在从课堂上删除练习，但 UI 没有更新。 这里是提供商的注册： Future<void> main() async { GlobalContextService.navigatorKey = GlobalKey<NavigatorState>(); WidgetsFlutterBinding.ensureInitialized(); await Firebase.initializeApp(); runApp( MultiProvider( providers: [ Provider<WorkoutProvider>(create: (_) => WorkoutProvider()), ], child: MaterialApp( debugShowCheckedModeBanner: false, routes: { '/' : (context) => AlreadyLoggedChecker(), '/login-screen': (context) => LoginScreen(), '/workout-review' : (context) => WorkoutReviewScreen(), '/create-training' : (context) => TrainingCreateScreen(), }, initialRoute: '/', ), ), ); } 我尝试添加一些 print()，这样当调用具有 notificationlistners() 的方法时，消费者就不会构建。 显然，在 ChangeNotifierProvider 中注册提供商时，我应该使用 Provider 而不是 main。

RetryTopic 如何与其他 groupId 和 backOff 属性一起使用

我正在使用 spring-kafka 和 @RetryTopic，我不明白这是如何工作的 对于不同的 groupId-s ： 例如，主题 TestTopic 包含 5 条消息，并且是 2 位消费者聆听 - 集团...

功能完成后消耗 JMS 消息

使用 MessageListener 从队列中消费消息后，它不会立即从队列中获取另一条消息。它正在等待我的功能完成，然后收到另一条消息...

虚拟主题中的消息未被消费者队列消费

我正在尝试使用 activemq 中的队列将虚拟主题中的消息出队。我尝试发送一些消息，它显示在“消息排队”下的主题中，但无法合并...

如何在x分钟关闭python中的kafka消费者？

我正在用python将一条kafka消息写入一个文件，并希望在x时间关闭消费者。 消费者 = KafkaConsumer(bootstrap_servers='xxx:xx', group_id=mygroupid, ...

如何将JSON加载到hive表中？

我有一个Python代码，它使用来自Kafka主题的消息。我想将这些消息存储到配置单元表中。 导入SSL 从 kafka 导入 KafkaConsumer、TopicPartition 从 pyhive 导入配置单元 SSL。

“RoutingSlipCompleted”不包含“GetVariable”的定义

使用massTransit（8.0.8）后我收到以下错误： “RoutingSlipCompleted”不包含“GetVariable”的定义 以及最好的扩展方法重载 'RoutingSlipEventExtensions.

Kafka消费者睡眠唤醒

您好，我有一个批处理使用Spring boot，其中一个kafka消费者在处理期间用@KafkaListener注释，有一个静态布尔值，在运行期间采用不同的值我想暂停我的

Dockerized Kakfa Consumer 未收到消息

我正在尝试在一个 docker 容器中的 kafka 生产者和在同一主机上的不同容器中运行的 kafka 消费者之间进行通信。 目前两个容器都在运行...

使用 Provider 替换 Flutter 中的 Widget

我在我的 Flutter 应用程序项目中使用 Provider 状态管理。 实际上，它的 OTP 屏幕分为 Widget： 输入电话号码小部件， 输入 OTP 小部件。 我无法更换我的第二个...

ActiveMQ Java STOMP 客户端收到 SocketTimeoutException

CentOS 机器上有一个 ActiveMQ 服务器。我可以使用 OpenWire JMS 客户端通过 TCP 和 HTTP 连接和使用消息。然而，当我尝试使用 ActiveMQ 测试 STOMP 客户端时

为什么用@StreamListener 注释的 kafka 侦听器表现不同于 kafka 侦听器实现消费者接口？

我们正在将 spring boot 2.2.6.release 升级到 2.7.8，并且在 Kafka 侦听器上面临以下问题。 场景-1： 以前我们使用 SCS 3.0.4.Release 并使用@StreamListener 消费 Kafka 乱七八糟的......

PHP Rabbitmq 如何检查消费者是否正在运行？

根据 Rabbitmq 文档，我编写了一个用于消费队列的脚本。但它是非常基本的例子。该脚本将作为 cron 运行，因为我需要确保它会恢复消耗过程，如果 previ ...

java中'void myMethod()'和'<T> void myMethod()'中'void'和'<T> void'的区别

public static void myMethod(int a, Consumer consumer){// 一些代码} public static void myMethod(int a, Consumer consumer){// 一些代码} 'void' 和 '...之间的区别

RabbitMQ 单消费者如何订阅多个流？ (C#)

是否可以在 RabbitMQ 中使用单个消费者订阅接收来自多个流的消息？ 我有以下代码来订阅单个流，并且可以正常工作。是吗

从 ListView Flutter 中移除元素

我在 Consumer 小部件中有一个 ListView 小部件。我想要实现的是在添加或删除新元素时更新 ListView 中的元素。 Consumer 和 ListView 的代码是...

无法在跨账户模式下将 aws lambda 消费者与 MSK 一起使用

我在 aws 帐户中有一个来自 kafka 团队的 MSK 集群设置，我们使用它来发布和使用来自主题的消息。目前，我们有基于 ec2 的 java 应用程序，在我们的开发 aws 帐户中......

Kafka + FastAPI + Docker 模板

简介 我目前正在试验 Kafka 和 FastAPI，并尝试构建一个模板，使我能够快速编写微服务模式的程序。 目标 - 愿景 构建存储库...