小编swa*_*ina的帖子

我提出一个共同的项目聆听异常和使用@ControllerAdvice与@ExceptionHandler

@ControllerAdvice(annotations = RestController.class)
public class RestResponseEntityExceptionHandler extends ResponseEntityExceptionHandler {

     @ExceptionHandler({Exception.class})
     @ResponseStatus(value = HttpStatus.NOT_FOUND)
     @ResponseBody
     public ResponseEntity<ErrorResponse> notFound(Exception ex) {
         return new ResponseEntity<>(
            new ErrorResponse(ex.getMessage(), 404, "My Custom Message"), HttpStatus.NOT_FOUND);
     }
}

没有任何@SpringBootApplication主要的方法来作为依赖添加到我的另一个项目中。我的pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.test</groupId>
<artifactId>spring-commons-rest</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>spring-commons-rest</name>
<description>for Listening Exceptions</description>

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.0.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency> …

Kafka 消费者组的滚动部署是否会导致该组冻结？

所以让我们考虑一下这个场景，

1. 我们开始滚动部署
2. 一位消费者离开了群组
3. Kafka 注意到这一点并触发重新平衡（因此消费停止）
4. 重新平衡发生了，但很快就有新的消费者想要加入
5. 另一个消费者也离开了
6. 再次发生新的重新平衡
7. （循环直到部署完成）

因此，如果您有一个足够大的集群，并且在一台机器上完成部署需要一些时间（通常是这种情况），这会导致消耗完全冻结吗？

如果是，在生产中进行消费者组更新的策略是什么