We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0ad0993 commit ae547aaCopy full SHA for ae547aa
1 file changed
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
@@ -1110,7 +1110,7 @@ private void handleInitiateApiVersionRequests(long now) {
1110
ApiVersionsRequest.Builder apiVersionRequestBuilder = entry.getValue();
1111
String clusterId = this.metadataUpdater.clusterId();
1112
int nodeId = Integer.parseInt(node);
1113
- if (clusterId != null && nodeId < Integer.MAX_VALUE/2) {
+ if (clusterId != null && nodeId < Integer.MAX_VALUE / 2) {
1114
System.out.println("CLUSTER_ID(" + clusterId + "), NODE_ID(" + nodeId + ")");
1115
apiVersionRequestBuilder.setClusterId(clusterId);
1116
apiVersionRequestBuilder.setNodeId(Integer.parseInt(node));
0 commit comments