diff --git a/app/src/main/java/org/astraea/app/checker/Checker.java b/app/src/main/java/org/astraea/app/checker/Checker.java index e255dc81a..79d0575a9 100644 --- a/app/src/main/java/org/astraea/app/checker/Checker.java +++ b/app/src/main/java/org/astraea/app/checker/Checker.java @@ -35,7 +35,7 @@ public class Checker { - private static final List GUARDS = List.of(new ProduceRpcGuard()); + private static final List GUARDS = List.of(new RpcGuard()); public static void main(String[] args) throws Exception { execute(Argument.parse(new Argument(), args)); @@ -45,7 +45,7 @@ public static void execute(final Argument param) throws Exception { try (var admin = Admin.create(Map.of("bootstrap.servers", param.bootstrapServers()))) { for (var guard : GUARDS) { var result = guard.run(admin, param.mBeanClientFunction(), param.readChangelog()); - System.out.println(result); + result.forEach(System.out::println); } } } diff --git a/app/src/main/java/org/astraea/app/checker/Report.java b/app/src/main/java/org/astraea/app/checker/Report.java index 49b22216a..8fd46469a 100644 --- a/app/src/main/java/org/astraea/app/checker/Report.java +++ b/app/src/main/java/org/astraea/app/checker/Report.java @@ -49,4 +49,12 @@ Stream stream() { if (why.isEmpty()) return Stream.empty(); return Stream.of(this); } + + @Override + public String toString() { + if (node == null) { + return "Report[pass]"; + } + return "Report[" + node + "] why = " + why; + } } diff --git a/app/src/main/java/org/astraea/app/checker/ProduceRpcGuard.java b/app/src/main/java/org/astraea/app/checker/RpcGuard.java similarity index 69% rename from app/src/main/java/org/astraea/app/checker/ProduceRpcGuard.java rename to app/src/main/java/org/astraea/app/checker/RpcGuard.java index ab4774b68..a4394b9c7 100644 --- a/app/src/main/java/org/astraea/app/checker/ProduceRpcGuard.java +++ b/app/src/main/java/org/astraea/app/checker/RpcGuard.java @@ -16,29 +16,36 @@ */ package org.astraea.app.checker; +import java.util.Arrays; import java.util.Collection; +import java.util.Map; import java.util.function.Function; import org.apache.kafka.clients.admin.Admin; import org.apache.kafka.common.Node; import org.astraea.common.metrics.MBeanClient; import org.astraea.common.metrics.broker.NetworkMetrics; -public class ProduceRpcGuard implements Guard { +public class RpcGuard implements Guard { @Override public Collection run( Admin admin, Function clients, Changelog changelog) throws Exception { + Map protocols = changelog.protocols(); return admin.describeCluster().nodes().get().stream() + .map(node -> checkNode(node, protocols, clients)) + .flatMap(Collection::stream) + .toList(); + } + + private Collection checkNode( + Node node, Map protocols, Function clients) { + return Arrays.stream(NetworkMetrics.Request.values()) + .filter(request -> protocols.containsKey(request.metricName().toLowerCase())) .map( - node -> { - var protocol = - changelog - .protocols() - .get(NetworkMetrics.Request.PRODUCE.metricName().toLowerCase()); - if (protocol == null) return Report.empty(); + request -> { + var protocol = protocols.get(request.metricName().toLowerCase()); var versions = NetworkMetrics.Request.PRODUCE.versions(clients.apply(node)); return Report.of(node, protocol, versions); }) - .flatMap(Report::stream) .toList(); } } diff --git a/common/src/main/java/org/astraea/common/metrics/broker/NetworkMetrics.java b/common/src/main/java/org/astraea/common/metrics/broker/NetworkMetrics.java index 083f75e24..1ccda57fd 100644 --- a/common/src/main/java/org/astraea/common/metrics/broker/NetworkMetrics.java +++ b/common/src/main/java/org/astraea/common/metrics/broker/NetworkMetrics.java @@ -141,7 +141,7 @@ public Set versions(MBeanClient mBeanClient) { BeanQuery.builder() .domainName("kafka.network") .property("type", "RequestMetrics") - .property("request", "Produce") + .property("request", this.metricName()) .property("name", "RequestsPerSec") .property("version", "*") .build()); diff --git a/config/kafka_changelog.json b/config/kafka_changelog.json index e97f844e4..36171f807 100644 --- a/config/kafka_changelog.json +++ b/config/kafka_changelog.json @@ -5,6 +5,354 @@ "base": 7, "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "fetch", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "listoffsets", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "metadata", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "controlledshutdown", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "offsetcommit", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "offsetfetch", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "findcoordinator", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "joingroup", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "heartbeat", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "leavegroup", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "syncgroup", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describegroups", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "listgroups", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "saslhandshake", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "apiversions", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "createtopics", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "deletetopics", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "deleterecords", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "initproducerid", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "offsetforleaderepoch", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "addpartitionstotxn", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "addoffsetstotxn", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "endtxn", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "writetxnmarkers", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "txnoffsetcommit", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describeacls", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "createacls", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "deleteacls", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describeconfigs", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "alterconfigs", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "alterreplicalogdirs", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describelogdirs", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "saslauthenticate", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "createpartitions", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "deletegroups", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "electleaders", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "incrementalalterconfigs", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "alterpartitionreassignments", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "listpartitionreassignments", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "offsetdelete", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describeclientquotas", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "alterclientquotas", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "vote", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "beginquorumepoch", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "endquorumepoch", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describequorum", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "alterpartition", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "updatefeatures", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "envelope", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "fetchsnapshot", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describecluster", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describeproducers", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "brokerregistration", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "brokerheartbeat", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "unregisterbroker", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "describetransactions", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "listtransactions", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" + }, + { + "name": "allocateproducerids", + "base": 7, + "commit": "https://github.com/apache/kafka/commit/fe56fc98fa736c79c9dcbb1f64f810065161a1cc", + "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0" } ], "configs": [ @@ -15,4 +363,4 @@ "kip": "https://cwiki.apache.org/confluence/display/KAFKA/KIP-500%3A+Replace+ZooKeeper+with+a+Self-Managed+Metadata+Quorum" } ] -} \ No newline at end of file +} diff --git a/docker/start_kafka.sh b/docker/start_kafka.sh index 662c9dff1..013b67a3e 100755 --- a/docker/start_kafka.sh +++ b/docker/start_kafka.sh @@ -135,4 +135,4 @@ docker run --rm \ -p 11113:11113 \ -d \ -e KAFKA_JMX_OPTS="$JMX2_OPTS" \ - "$IMAGE_NAME" bin/kafka-server-start.sh config/server2.properties \ No newline at end of file + "$IMAGE_NAME" bin/kafka-server-start.sh config/server2.properties