root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix potential NPE (#17541) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Dmitry Werner 2024-10-18 22:05:45 +05:00 committed by GitHub
parent b917b85e62
commit eb897c6ad5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java
View File

@ -1209,7 +1209,7 @@ public class ValuesTest {
}
protected SchemaAndValue roundTrip(Schema desiredSchema, SchemaAndValue input) {
String serialized = Values.convertToString(input.schema(), input.value());
String serialized = input != null ? Values.convertToString(input.schema(), input.value()) : null;
if (input != null && input.value() != null) {
assertNotNull(serialized);
}

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java
View File

@ -329,7 +329,7 @@ public class ConsumerGroup extends ModernGroup<ConsumerGroupMember> {
* @param oldMember The member to remove.
*/
private void removeStaticMember(ConsumerGroupMember oldMember) {
if (oldMember.instanceId() != null) {
if (oldMember != null && oldMember.instanceId() != null) {
staticMembers.remove(oldMember.instanceId());
}
}