当前位置: 首页 > 知识库问答 >
问题:

Spring Kafka用户在主题空闲时从用户组中移除

羊舌源
2023-03-14

Spring Boot 1.5.x、Spring Boot 2.4.x、Apache Kafka 0.10.2

情况

问题

  1. 是否有Spring Boot/Spring Kafka正在设置的设置或属性会导致一两天内未使用空闲主题中的任何记录的用户从用户组中删除?
  2. 如果是,可以关闭吗?有什么缺点?
  3. 如果没有,是否有一种方法可以重新加入消费者组而不必重新启动服务?有什么缺点?

共有1个答案

越嘉石
2023-03-14

那个Kafka版本已经非常非常古老了。

旧版本在24小时没有活动后删除了消费者抵消,即使消费者仍然连接。在2.0中,这增加到7天。对于较新的代理(从2.1开始),只有当消费者在7天内没有实际连接时,消费者抵消才会被移除。

参见https://kafka.apache.org/documentation/#upgrade_200_notable

可以使用旧的代理增加代理的offsets.retention.minutes

 类似资料:
  • 问题内容: 我正在尝试使用JavaFX作为UI制作一个简单的Java交易应用。 我现在想要做的是从具有1个主要阶段和许多场景的应用程序中检测用户空闲状态。 示例:如果用户闲置了3分钟,则返回主菜单。 我已经在网络上尝试过一些有关如何检测JavaFX空闲状态的示例,但是我发现的始终是-一种在所有场景中都发生的功能空闲状态检测- 这种方法对交易应用程序(我认为)很危险(例如:应用程序检测交易过程中处于

  • 问题内容: 如何在Go HTTP客户端中使空闲超时? 空闲超时意味着从HTTP客户端内部调用Conn接口的Read / Write方法时发生超时。当客户端下载文件并且由于读取超时而导致下载失败时,此功能很有用。 问题答案: 您需要创建自己的,并返回,以设置适当的读写期限。 该会是这个样子:

  • 我正在尝试将LDAP用户和组导入Liferay6.1。 在之后,只能从LDAP导入用户,而不能导入 有什么建议吗。

  • Kafka使用者(org.apache.Kafka:kafka-clients:2.3.0)应该使用来自一个分区的主题的消息。 该服务记录使用者订阅,但它不使用消息,也不使用官方的Apache工具显示在使用者组列表中。

  • 问题内容: 我需要在〜/ .config / myapp.cfg中创建一个配置文件,所以我要使用: 问题是,它告诉我,该目录不存在,类似这样。 我尝试将路径更改为/ home / user之类的东西,它起作用了。所以我设法得出一个结论,即java不知道〜/的含义以及文件夹名前的punct(。)的含义,因为/home/user/.config也无法正常工作。 我该怎么办? 问题答案: 这种表示法是一