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 incorrect Java equals comparison of Uuid by reference (#15707) 

Reviewers: Justine Olshan <jolshan@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Alok Thatikunta 2024-04-13 18:25:48 +05:30 committed by GitHub
parent e02ffd852f
commit c034cf2953
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
View File

@ -1702,7 +1702,7 @@ public class KafkaAdminClient extends AdminClient {
}
private static boolean topicIdIsUnrepresentable(Uuid topicId) {
return topicId == null || topicId == Uuid.ZERO_UUID;
return topicId == null || topicId.equals(Uuid.ZERO_UUID);
}
// for testing

2
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java
View File

@ -112,7 +112,7 @@ public class MetadataResponse extends AbstractResponse {
public Map<Uuid, Errors> errorsByTopicId() {
Map<Uuid, Errors> errors = new HashMap<>();
for (MetadataResponseTopic metadata : data.topics()) {
if (metadata.topicId() == Uuid.ZERO_UUID) {
if (metadata.topicId().equals(Uuid.ZERO_UUID)) {
throw new IllegalStateException("Use errors() when managing topic using topic name");
}
if (metadata.errorCode() != Errors.NONE.code())

2
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java
View File

@ -133,7 +133,7 @@ public class ClientTelemetryUtils {
}
public static Uuid validateClientInstanceId(Uuid clientInstanceId) {
if (clientInstanceId == null || clientInstanceId == Uuid.ZERO_UUID) {
if (clientInstanceId == null || clientInstanceId.equals(Uuid.ZERO_UUID)) {
throw new IllegalArgumentException("clientInstanceId is not valid");
}

6
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/PartitionMetadataFile.java
View File

@ -63,9 +63,9 @@ public class PartitionMetadataFile {
public void record(Uuid topicId) {
// Topic IDs should not differ, but we defensively check here to fail earlier in the case that the IDs somehow differ.
dirtyTopicIdOpt.ifPresent(dirtyTopicId -> {
if (dirtyTopicId != topicId) {
throw new InconsistentTopicIdException("Tried to record topic ID $topicId to file " +
"but had already recorded $dirtyTopicId");
if (!dirtyTopicId.equals(topicId)) {
throw new InconsistentTopicIdException("Tried to record topic ID " + topicId + " to file " +
"but had already recorded " + dirtyTopicId);
}
});
dirtyTopicIdOpt = Optional.of(topicId);

4
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java
View File

@ -296,7 +296,7 @@ public abstract class TopicCommand {
.map(ce -> ce.name() + "=" + ce.value())
.collect(Collectors.joining(","));
System.out.print("Topic: " + topic);
if (topicId != Uuid.ZERO_UUID)
if (!topicId.equals(Uuid.ZERO_UUID))
System.out.print("\tTopicId: " + topicId);
System.out.print("\tPartitionCount: " + numPartitions);
System.out.print("\tReplicationFactor: " + replicationFactor);
@ -539,7 +539,7 @@ public abstract class TopicCommand {
public void describeTopic(TopicCommandOptions opts) throws ExecutionException, InterruptedException {
// If topicId is provided and not zero, will use topicId regardless of topic name
Optional<Uuid> inputTopicId = opts.topicId()
.map(Uuid::fromString).filter(uuid -> uuid != Uuid.ZERO_UUID);
.map(Uuid::fromString).filter(uuid -> !uuid.equals(Uuid.ZERO_UUID));
Boolean useTopicId = inputTopicId.isPresent();
List<Uuid> topicIds;