Skip to content

Commit

Permalink
Removed unused method (#960)
Browse files Browse the repository at this point in the history
Signed-off-by: Paolo Patierno <[email protected]>
  • Loading branch information
ppatierno authored Jan 11, 2025
1 parent c3a1553 commit 9969bed
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@ public void doGetTopic(RoutingContext routingContext) {
ArrayNode partitionsArray = JsonUtils.createArrayNode();
root.put("name", topicName);
Collection<ConfigEntry> configEntries = configDescriptions.values().iterator().next().entries();
if (configEntries.size() > 0) {
if (!configEntries.isEmpty()) {
ObjectNode configs = JsonUtils.createObjectNode();
configEntries.forEach(configEntry -> configs.put(configEntry.name(), configEntry.value()));
root.set("configs", configs);
Expand Down
12 changes: 0 additions & 12 deletions src/main/java/io/strimzi/kafka/bridge/http/HttpBridge.java
Original file line number Diff line number Diff line change
Expand Up @@ -639,18 +639,6 @@ private void closeConnectionEndpoint(HttpConnection connection) {
}
}

private EmbeddedFormat contentTypeToFormat(String contentType) {
switch (contentType) {
case BridgeContentType.KAFKA_JSON_BINARY:
return EmbeddedFormat.BINARY;
case BridgeContentType.KAFKA_JSON_JSON:
return EmbeddedFormat.JSON;
case BridgeContentType.KAFKA_JSON_TEXT:
return EmbeddedFormat.TEXT;
}
throw new IllegalArgumentException(contentType);
}

private boolean isAlive() {
return this.isReady;
}
Expand Down

0 comments on commit 9969bed

Please sign in to comment.