This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f4afec0cb2e MINOR: Fix double negative typos in Javadoc and exception
messages (#21977)
f4afec0cb2e is described below
commit f4afec0cb2e6348d527d032f20ff7f1d9400185d
Author: 조형준 <[email protected]>
AuthorDate: Wed Apr 8 21:55:41 2026 +0900
MINOR: Fix double negative typos in Javadoc and exception messages (#21977)
Fix repeated word `not` in ConnectException messages.
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../kafka/clients/admin/DescribeClusterOptions.java | 4 ++--
.../kafka/connect/util/clusters/EmbeddedConnect.java | 20 ++++++++++----------
.../processor/internals/InternalTopologyBuilder.java | 2 +-
3 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java
b/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java
index b62cefcdb44..910b64fb428 100644
---
a/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java
+++
b/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java
@@ -49,7 +49,7 @@ public class DescribeClusterOptions extends
AbstractOptions<DescribeClusterOptio
/**
* Specify if authorized operations should be included in the response.
Note that some
- * older brokers cannot not supply this information even if it is
requested.
+ * older brokers cannot supply this information even if it is requested.
*/
public boolean includeAuthorizedOperations() {
return includeAuthorizedOperations;
@@ -57,7 +57,7 @@ public class DescribeClusterOptions extends
AbstractOptions<DescribeClusterOptio
/**
* Specify if fenced brokers should be included in the response. Note
that some
- * older brokers cannot not supply this information even if it is
requested.
+ * older brokers cannot supply this information even if it is requested.
*/
public boolean includeFencedBrokers() {
return includeFencedBrokers;
diff --git
a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
index ddd7eab4e8b..c8caf8889eb 100644
---
a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
+++
b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
@@ -504,7 +504,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read connector state from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse connector state",
e);
+ throw new ConnectException("Could not parse connector state", e);
}
}
/**
@@ -525,7 +525,7 @@ abstract class EmbeddedConnect {
log.error("Could not parse connector list from response: {}",
responseToString(response), e
);
- throw new ConnectException("Could not not parse connector
list", e);
+ throw new ConnectException("Could not parse connector list",
e);
}
}
throw new ConnectRestException(response.getStatus(),
@@ -552,7 +552,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read connector state from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse connector state",
e);
+ throw new ConnectException("Could not parse connector state", e);
}
throw new ConnectRestException(response.getStatus(),
"Could not read connector state. Error response: " +
responseToString(response));
@@ -581,7 +581,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read connector state from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse connector state",
e);
+ throw new ConnectException("Could not parse connector state", e);
}
throw new ConnectRestException(response.getStatus(),
"Could not read connector state. Error response: " +
responseToString(response));
@@ -604,7 +604,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read connector info from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse connector info",
e);
+ throw new ConnectException("Could not parse connector info", e);
}
throw new ConnectRestException(response.getStatus(),
"Could not read connector info. Error response: " +
responseToString(response));
@@ -629,7 +629,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read task configs from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse task configs", e);
+ throw new ConnectException("Could not parse task configs", e);
}
throw new ConnectRestException(response.getStatus(),
"Could not read task configs. Error response: " +
responseToString(response));
@@ -668,7 +668,7 @@ abstract class EmbeddedConnect {
return
mapper.readerFor(ConnectorOffsets.class).readValue(responseToString(response));
}
} catch (IOException e) {
- throw new ConnectException("Could not not parse connector
offsets", e);
+ throw new ConnectException("Could not parse connector offsets", e);
}
throw new ConnectRestException(response.getStatus(),
"Could not fetch connector offsets. Error response: " +
responseToString(response));
@@ -768,7 +768,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read logger level from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse logger level",
e);
+ throw new ConnectException("Could not parse logger level", e);
}
} else {
throw new ConnectRestException(
@@ -796,7 +796,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read logger levels from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse logger
levels", e);
+ throw new ConnectException("Could not parse logger levels", e);
}
} else {
throw new ConnectRestException(
@@ -842,7 +842,7 @@ abstract class EmbeddedConnect {
} catch (IOException e) {
log.error("Could not read loggers from response: {}",
responseToString(response), e);
- throw new ConnectException("Could not not parse loggers", e);
+ throw new ConnectException("Could not parse loggers", e);
}
} else {
throw new ConnectRestException(
diff --git
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
index efdbf7d5974..a19bbcc50eb 100644
---
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
+++
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
@@ -625,7 +625,7 @@ public class InternalTopologyBuilder {
if (processorNames != null) {
for (final String processorName : processorNames) {
- Objects.requireNonNull(processorName, "processor cannot not be
null");
+ Objects.requireNonNull(processorName, "processor cannot be
null");
connectProcessorAndStateStore(processorName, storeName);
}
}
