MINOR: Add proper checks to KafkaConsumer.groupMetadata (#9349)
Add following checks to `KafkaConsumer.groupMetadata`: 1. null check of coordinator (replace NPE by `InvalidGroupIdException` which is same to other methods) 2. concurrent check (`groupMetadata` is not thread-safe so concurrent check is necessary) Reviewers: Jason Gustafson <jason@confluent.io>
显示
- clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java 8 个添加, 1 个删除...java/org/apache/kafka/clients/consumer/KafkaConsumer.java
- clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java 30 个添加, 0 个删除.../org/apache/kafka/clients/consumer/KafkaConsumerTest.java
加载中
想要评论请 注册 或 登录