pxchek
commented
2 years ago Closed pxchek closed 2 years ago
pxchek
commented
2 years ago pxchek
commented
2 years ago /Library/Java/JavaVirtualMachines/sapmachine-jdk-11.0.10.jdk/Contents/Home/bin/java -Dvisualvm.id=22769466677763 -javaagent:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar=61966:/Applications/IntelliJ IDEA.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Users/ypxc026/IdeaProjects/kafka-streams/target/classes:/Users/ypxc026/.m2/repository/org/springframework/boot/spring-boot-starter/2.5.4/spring-boot-starter-2.5.4.jar:/Users/ypxc026/.m2/repository/org/springframework/boot/spring-boot/2.5.4/spring-boot-2.5.4.jar:/Users/ypxc026/.m2/repository/org/springframework/boot/spring-boot-autoconfigure/2.5.4/spring-boot-autoconfigure-2.5.4.jar:/Users/ypxc026/.m2/repository/org/springframework/boot/spring-boot-starter-logging/2.5.4/spring-boot-starter-logging-2.5.4.jar:/Users/ypxc026/.m2/repository/ch/qos/logback/logback-classic/1.2.5/logback-classic-1.2.5.jar:/Users/ypxc026/.m2/repository/ch/qos/logback/logback-core/1.2.5/logback-core-1.2.5.jar:/Users/ypxc026/.m2/repository/org/apache/logging/log4j/log4j-to-slf4j/2.14.1/log4j-to-slf4j-2.14.1.jar:/Users/ypxc026/.m2/repository/org/apache/logging/log4j/log4j-api/2.14.1/log4j-api-2.14.1.jar:/Users/ypxc026/.m2/repository/org/slf4j/jul-to-slf4j/1.7.32/jul-to-slf4j-1.7.32.jar:/Users/ypxc026/.m2/repository/jakarta/annotation/jakarta.annotation-api/1.3.5/jakarta.annotation-api-1.3.5.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-core/5.3.9/spring-core-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-jcl/5.3.9/spring-jcl-5.3.9.jar:/Users/ypxc026/.m2/repository/org/yaml/snakeyaml/1.28/snakeyaml-1.28.jar:/Users/ypxc026/.m2/repository/org/apache/kafka/kafka-streams/2.7.1/kafka-streams-2.7.1.jar:/Users/ypxc026/.m2/repository/org/apache/kafka/kafka-clients/2.7.1/kafka-clients-2.7.1.jar:/Users/ypxc026/.m2/repository/com/github/luben/zstd-jni/1.4.5-6/zstd-jni-1.4.5-6.jar:/Users/ypxc026/.m2/repository/org/lz4/lz4-java/1.7.1/lz4-java-1.7.1.jar:/Users/ypxc026/.m2/repository/org/xerial/snappy/snappy-java/1.1.7.7/snappy-java-1.1.7.7.jar:/Users/ypxc026/.m2/repository/org/apache/kafka/connect-json/2.7.1/connect-json-2.7.1.jar:/Users/ypxc026/.m2/repository/org/apache/kafka/connect-api/2.7.1/connect-api-2.7.1.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.12.4/jackson-databind-2.12.4.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.12.4/jackson-annotations-2.12.4.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.12.4/jackson-core-2.12.4.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jdk8/2.12.4/jackson-datatype-jdk8-2.12.4.jar:/Users/ypxc026/.m2/repository/org/slf4j/slf4j-api/1.7.32/slf4j-api-1.7.32.jar:/Users/ypxc026/.m2/repository/org/rocksdb/rocksdbjni/5.18.4/rocksdbjni-5.18.4.jar:/Users/ypxc026/.m2/repository/org/springframework/kafka/spring-kafka/2.7.6/spring-kafka-2.7.6.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-context/5.3.9/spring-context-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-aop/5.3.9/spring-aop-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-beans/5.3.9/spring-beans-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-expression/5.3.9/spring-expression-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-messaging/5.3.9/spring-messaging-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/spring-tx/5.3.9/spring-tx-5.3.9.jar:/Users/ypxc026/.m2/repository/org/springframework/retry/spring-retry/1.3.1/spring-retry-1.3.1.jar:/Users/ypxc026/.m2/repository/javax/annotation/javax.annotation-api/1.3.2/javax.annotation-api-1.3.2.jar:/Users/ypxc026/.m2/repository/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar:/Users/ypxc026/.m2/repository/jakarta/xml/bind/jakarta.xml.bind-api/2.3.3/jakarta.xml.bind-api-2.3.3.jar:/Users/ypxc026/.m2/repository/jakarta/activation/jakarta.activation-api/1.2.2/jakarta.activation-api-1.2.2.jar:/Users/ypxc026/.m2/repository/org/apache/zookeeper/zookeeper/3.5.9/zookeeper-3.5.9.jar:/Users/ypxc026/.m2/repository/org/apache/zookeeper/zookeeper-jute/3.5.9/zookeeper-jute-3.5.9.jar:/Users/ypxc026/.m2/repository/org/apache/yetus/audience-annotations/0.5.0/audience-annotations-0.5.0.jar:/Users/ypxc026/.m2/repository/io/netty/netty-transport-native-epoll/4.1.67.Final/netty-transport-native-epoll-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-jms-client-all/2.18.0/artemis-jms-client-all-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-boot/2.18.0/artemis-boot-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-server/2.17.0/artemis-server-2.17.0.jar:/Users/ypxc026/.m2/repository/com/google/guava/guava/30.1-jre/guava-30.1-jre.jar:/Users/ypxc026/.m2/repository/com/google/guava/failureaccess/1.0.1/failureaccess-1.0.1.jar:/Users/ypxc026/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/ypxc026/.m2/repository/org/checkerframework/checker-qual/3.5.0/checker-qual-3.5.0.jar:/Users/ypxc026/.m2/repository/com/google/errorprone/error_prone_annotations/2.3.4/error_prone_annotations-2.3.4.jar:/Users/ypxc026/.m2/repository/com/google/j2objc/j2objc-annotations/1.3/j2objc-annotations-1.3.jar:/Users/ypxc026/.m2/repository/org/jboss/logging/jboss-logging/3.4.2.Final/jboss-logging-3.4.2.Final.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-commons/2.17.0/artemis-commons-2.17.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-selector/2.17.0/artemis-selector-2.17.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-journal/2.17.0/artemis-journal-2.17.0.jar:/Users/ypxc026/.m2/repository/org/jctools/jctools-core/2.1.2/jctools-core-2.1.2.jar:/Users/ypxc026/.m2/repository/io/netty/netty-buffer/4.1.67.Final/netty-buffer-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-transport/4.1.67.Final/netty-transport-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-resolver/4.1.67.Final/netty-resolver-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-codec-http/4.1.67.Final/netty-codec-http-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-common/4.1.67.Final/netty-common-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-handler/4.1.67.Final/netty-handler-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-transport-native-epoll/4.1.67.Final/netty-transport-native-epoll-4.1.67.Final-linux-x86_64.jar:/Users/ypxc026/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.67.Final/netty-transport-native-unix-common-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-transport-native-kqueue/4.1.67.Final/netty-transport-native-kqueue-4.1.67.Final-osx-x86_64.jar:/Users/ypxc026/.m2/repository/io/netty/netty-codec/4.1.67.Final/netty-codec-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/org/apache/commons/commons-configuration2/2.7/commons-configuration2-2.7.jar:/Users/ypxc026/.m2/repository/org/apache/commons/commons-text/1.8/commons-text-1.8.jar:/Users/ypxc026/.m2/repository/io/micrometer/micrometer-core/1.7.3/micrometer-core-1.7.3.jar:/Users/ypxc026/.m2/repository/org/hdrhistogram/HdrHistogram/2.1.12/HdrHistogram-2.1.12.jar:/Users/ypxc026/.m2/repository/org/latencyutils/LatencyUtils/2.0.3/LatencyUtils-2.0.3.jar:/Users/ypxc026/.m2/repository/commons-io/commons-io/2.6/commons-io-2.6.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-dto/2.18.0/artemis-dto-2.18.0.jar:/Users/ypxc026/.m2/repository/com/sun/xml/bind/jaxb-impl/2.3.3/jaxb-impl-2.3.3.jar:/Users/ypxc026/.m2/repository/com/sun/activation/jakarta.activation/1.2.2/jakarta.activation-1.2.2.jar:/Users/ypxc026/.m2/repository/com/sun/xml/bind/jaxb-jxc/2.3.3/jaxb-jxc-2.3.3.jar:/Users/ypxc026/.m2/repository/com/sun/xml/bind/jaxb-xjc/2.3.3/jaxb-xjc-2.3.3.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-cli/2.18.0/artemis-cli-2.18.0.jar:/Users/ypxc026/.m2/repository/jakarta/inject/jakarta.inject-api/1.0.3/jakarta.inject-api-1.0.3.jar:/Users/ypxc026/.m2/repository/jakarta/jms/jakarta.jms-api/2.0.3/jakarta.jms-api-2.0.3.jar:/Users/ypxc026/.m2/repository/org/apache/commons/commons-lang3/3.12.0/commons-lang3-3.12.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-jms-server/2.17.0/artemis-jms-server-2.17.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-service-extensions/2.17.0/artemis-service-extensions-2.17.0.jar:/Users/ypxc026/.m2/repository/org/apache/geronimo/specs/geronimo-jms_2.0_spec/1.0-alpha-2/geronimo-jms_2.0_spec-1.0-alpha-2.jar:/Users/ypxc026/.m2/repository/org/apache/geronimo/specs/geronimo-jta_1.1_spec/1.1.1/geronimo-jta_1.1_spec-1.1.1.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-jms-client/2.17.0/artemis-jms-client-2.17.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-ra/2.18.0/artemis-ra-2.18.0.jar:/Users/ypxc026/.m2/repository/org/jgroups/jgroups/3.6.13.Final/jgroups-3.6.13.Final.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-spring-integration/2.18.0/artemis-spring-integration-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/rest/artemis-rest/2.18.0/artemis-rest-2.18.0.jar:/Users/ypxc026/.m2/repository/org/jboss/resteasy/resteasy-jaxrs/3.15.0.Final/resteasy-jaxrs-3.15.0.Final.jar:/Users/ypxc026/.m2/repository/org/jboss/spec/javax/ws/rs/jboss-jaxrs-api_2.1_spec/2.0.1.Final/jboss-jaxrs-api_2.1_spec-2.0.1.Final.jar:/Users/ypxc026/.m2/repository/org/jboss/spec/javax/xml/bind/jboss-jaxb-api_2.3_spec/2.0.1.Final/jboss-jaxb-api_2.3_spec-2.0.1.Final.jar:/Users/ypxc026/.m2/repository/org/reactivestreams/reactive-streams/1.0.3/reactive-streams-1.0.3.jar:/Users/ypxc026/.m2/repository/jakarta/validation/jakarta.validation-api/2.0.2/jakarta.validation-api-2.0.2.jar:/Users/ypxc026/.m2/repository/org/jboss/spec/javax/annotation/jboss-annotations-api_1.3_spec/2.0.1.Final/jboss-annotations-api_1.3_spec-2.0.1.Final.jar:/Users/ypxc026/.m2/repository/com/github/stephenc/jcip/jcip-annotations/1.0-1/jcip-annotations-1.0-1.jar:/Users/ypxc026/.m2/repository/org/jboss/resteasy/resteasy-jaxb-provider/3.15.0.Final/resteasy-jaxb-provider-3.15.0.Final.jar:/Users/ypxc026/.m2/repository/org/glassfish/jaxb/jaxb-runtime/2.3.5/jaxb-runtime-2.3.5.jar:/Users/ypxc026/.m2/repository/org/glassfish/jaxb/txw2/2.3.5/txw2-2.3.5.jar:/Users/ypxc026/.m2/repository/com/sun/istack/istack-commons-runtime/3.0.12/istack-commons-runtime-3.0.12.jar:/Users/ypxc026/.m2/repository/org/jboss/resteasy/resteasy-jackson2-provider/3.15.0.Final/resteasy-jackson2-provider-3.15.0.Final.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-json-provider/2.12.4/jackson-jaxrs-json-provider-2.12.4.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-base/2.12.4/jackson-jaxrs-base-2.12.4.jar:/Users/ypxc026/.m2/repository/com/fasterxml/jackson/module/jackson-module-jaxb-annotations/2.12.4/jackson-module-jaxb-annotations-2.12.4.jar:/Users/ypxc026/.m2/repository/com/github/fge/json-patch/1.9/json-patch-1.9.jar:/Users/ypxc026/.m2/repository/com/github/fge/jackson-coreutils/1.6/jackson-coreutils-1.6.jar:/Users/ypxc026/.m2/repository/com/github/fge/msg-simple/1.1/msg-simple-1.1.jar:/Users/ypxc026/.m2/repository/com/github/fge/btf/1.2/btf-1.2.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-commons/2.18.0/artemis-commons-2.18.0-tests.jar:/Users/ypxc026/.m2/repository/jakarta/ws/rs/jakarta.ws.rs-api/2.1.6/jakarta.ws.rs-api-2.1.6.jar:/Users/ypxc026/.m2/repository/org/apache/httpcomponents/httpcore/4.4.14/httpcore-4.4.14.jar:/Users/ypxc026/.m2/repository/org/apache/httpcomponents/httpclient/4.5.13/httpclient-4.5.13.jar:/Users/ypxc026/.m2/repository/commons-codec/commons-codec/1.15/commons-codec-1.15.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-web/2.18.0/artemis-web-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-core-client/2.17.0/artemis-core-client-2.17.0.jar:/Users/ypxc026/.m2/repository/io/netty/netty-handler-proxy/4.1.67.Final/netty-handler-proxy-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-codec-socks/4.1.67.Final/netty-codec-socks-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-amqp-protocol/2.17.0/artemis-amqp-protocol-2.17.0.jar:/Users/ypxc026/.m2/repository/org/apache/qpid/proton-j/0.33.8/proton-j-0.33.8.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-stomp-protocol/2.18.0/artemis-stomp-protocol-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-openwire-protocol/2.18.0/artemis-openwire-protocol-2.18.0.jar:/Users/ypxc026/.m2/repository/org/fusesource/hawtbuf/hawtbuf/1.11/hawtbuf-1.11.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-hornetq-protocol/2.18.0/artemis-hornetq-protocol-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-hqclient-protocol/2.18.0/artemis-hqclient-protocol-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-mqtt-protocol/2.18.0/artemis-mqtt-protocol-2.18.0.jar:/Users/ypxc026/.m2/repository/org/jboss/logging/jboss-logging-processor/2.2.0.Final/jboss-logging-processor-2.2.0.Final.jar:/Users/ypxc026/.m2/repository/org/jboss/logging/jboss-logging-annotations/2.2.0.Final/jboss-logging-annotations-2.2.0.Final.jar:/Users/ypxc026/.m2/repository/org/jboss/jdeparser/jdeparser/2.0.3.Final/jdeparser-2.0.3.Final.jar:/Users/ypxc026/.m2/repository/io/netty/netty-codec-mqtt/4.1.67.Final/netty-codec-mqtt-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/activemq-artemis-native/1.0.2/activemq-artemis-native-1.0.2.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-jdbc-store/2.18.0/artemis-jdbc-store-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/commons/commons-dbcp2/2.8.0/commons-dbcp2-2.8.0.jar:/Users/ypxc026/.m2/repository/org/apache/commons/commons-pool2/2.9.0/commons-pool2-2.9.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-website/2.18.0/artemis-website-2.18.0.jar:/Users/ypxc026/.m2/repository/org/jboss/logmanager/jboss-logmanager/2.1.10.Final/jboss-logmanager-2.1.10.Final.jar:/Users/ypxc026/.m2/repository/org/jboss/slf4j/slf4j-jboss-logmanager/1.0.4.GA/slf4j-jboss-logmanager-1.0.4.GA.jar:/Users/ypxc026/.m2/repository/org/wildfly/common/wildfly-common/1.5.2.Final/wildfly-common-1.5.2.Final.jar:/Users/ypxc026/.m2/repository/io/airlift/airline/0.8/airline-0.8.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/activemq-client/5.16.3/activemq-client-5.16.3.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/activemq-openwire-legacy/5.16.3/activemq-openwire-legacy-5.16.3.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/aggregate/jetty-all/9.4.43.v20210629/jetty-all-9.4.43.v20210629-uber.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-client/9.4.43.v20210629/jetty-client-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-http/9.4.43.v20210629/jetty-http-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-io/9.4.43.v20210629/jetty-io-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-deploy/9.4.43.v20210629/jetty-deploy-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-webapp/9.4.43.v20210629/jetty-webapp-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-servlet/9.4.43.v20210629/jetty-servlet-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-util-ajax/9.4.43.v20210629/jetty-util-ajax-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-xml/9.4.43.v20210629/jetty-xml-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-jmx/9.4.43.v20210629/jetty-jmx-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-plus/9.4.43.v20210629/jetty-plus-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-annotations/9.4.43.v20210629/jetty-annotations-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/ow2/asm/asm/9.1/asm-9.1.jar:/Users/ypxc026/.m2/repository/org/ow2/asm/asm-commons/9.1/asm-commons-9.1.jar:/Users/ypxc026/.m2/repository/org/ow2/asm/asm-tree/9.1/asm-tree-9.1.jar:/Users/ypxc026/.m2/repository/org/ow2/asm/asm-analysis/9.1/asm-analysis-9.1.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-util/9.4.43.v20210629/jetty-util-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-jaspi/9.4.43.v20210629/jetty-jaspi-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-security/9.4.43.v20210629/jetty-security-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/orbit/javax.security.auth.message/1.0.0.v201108011116/javax.security.auth.message-1.0.0.v201108011116.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-jndi/9.4.43.v20210629/jetty-jndi-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-rewrite/9.4.43.v20210629/jetty-rewrite-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-server/9.4.43.v20210629/jetty-server-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-servlets/9.4.43.v20210629/jetty-servlets-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-continuation/9.4.43.v20210629/jetty-continuation-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-quickstart/9.4.43.v20210629/jetty-quickstart-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/javax/transaction/javax.transaction-api/1.3/javax.transaction-api-1.3.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/websocket-servlet/9.4.43.v20210629/websocket-servlet-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/websocket-api/9.4.43.v20210629/websocket-api-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/javax-websocket-server-impl/9.4.43.v20210629/javax-websocket-server-impl-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/javax-websocket-client-impl/9.4.43.v20210629/javax-websocket-client-impl-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/javax/websocket/javax.websocket-client-api/1.0/javax.websocket-client-api-1.0.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/websocket-server/9.4.43.v20210629/websocket-server-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/websocket-client/9.4.43.v20210629/websocket-client-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/websocket/websocket-common/9.4.43.v20210629/websocket-common-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/jetty-alpn-client/9.4.43.v20210629/jetty-alpn-client-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/http2/http2-server/9.4.43.v20210629/http2-server-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/http2/http2-common/9.4.43.v20210629/http2-common-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/http2/http2-hpack/9.4.43.v20210629/http2-hpack-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/http2/http2-client/9.4.43.v20210629/http2-client-9.4.43.v20210629.jar:/Users/ypxc026/.m2/repository/javax/websocket/javax.websocket-api/1.1/javax.websocket-api-1.1.jar:/Users/ypxc026/.m2/repository/javax/servlet/javax.servlet-api/4.0.1/javax.servlet-api-4.0.1.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/orbit/javax.mail.glassfish/1.4.1.v201005082020/javax.mail.glassfish-1.4.1.v201005082020.jar:/Users/ypxc026/.m2/repository/org/eclipse/jetty/orbit/javax.activation/1.1.0.v201105071233/javax.activation-1.1.0.v201105071233.jar:/Users/ypxc026/.m2/repository/org/apache/tomcat/tomcat-servlet-api/8.5.5/tomcat-servlet-api-8.5.5.jar:/Users/ypxc026/.m2/repository/org/apache/qpid/qpid-jms-client/0.59.0/qpid-jms-client-0.59.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-console/2.18.0/artemis-console-2.18.0.war:/Users/ypxc026/.m2/repository/org/apache/activemq/activemq-branding/2.18.0/activemq-branding-2.18.0.war:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-plugin/2.18.0/artemis-plugin-2.18.0.war:/Users/ypxc026/.m2/repository/commons-beanutils/commons-beanutils/1.9.4/commons-beanutils-1.9.4.jar:/Users/ypxc026/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/ypxc026/.m2/repository/commons-logging/commons-logging/1.2/commons-logging-1.2.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-website/2.18.0/artemis-website-2.18.0-javadoc.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-quorum-api/2.18.0/artemis-quorum-api-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/activemq/artemis-quorum-ri/2.18.0/artemis-quorum-ri-2.18.0.jar:/Users/ypxc026/.m2/repository/org/apache/curator/curator-recipes/5.1.0/curator-recipes-5.1.0.jar:/Users/ypxc026/.m2/repository/org/apache/curator/curator-framework/5.1.0/curator-framework-5.1.0.jar:/Users/ypxc026/.m2/repository/org/apache/curator/curator-client/5.1.0/curator-client-5.1.0.jar:/Users/ypxc026/.m2/repository/org/apache/curator/curator-test/5.1.0/curator-test-5.1.0.jar:/Users/ypxc026/.m2/repository/io/dropwizard/metrics/metrics-core/4.1.25/metrics-core-4.1.25.jar:/Users/ypxc026/.m2/repository/io/netty/netty-all/4.1.67.Final/netty-all-4.1.67.Final.jar:/Users/ypxc026/.m2/repository/jakarta/json/jakarta.json-api/1.1.6/jakarta.json-api-1.1.6.jar:/Users/ypxc026/.m2/repository/org/apache/johnzon/johnzon-core/1.2.14/johnzon-core-1.2.14.jar:/Users/ypxc026/.m2/repository/jakarta/security/auth/message/jakarta.security.auth.message-api/1.1.3/jakarta.security.auth.message-api-1.1.3.jar com.example.productreviews.KafkaJsonReviewDataProducerWorker
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/ypxc026/.m2/repository/ch/qos/logback/logback-classic/1.2.5/logback-classic-1.2.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/ypxc026/.m2/repository/org/jboss/slf4j/slf4j-jboss-logmanager/1.0.4.GA/slf4j-jboss-logmanager-1.0.4.GA.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [ch.qos.logback.classic.util.ContextSelectorStaticBinder]
13:59:02.863 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:
acks = 1
batch.size = 16384
bootstrap.servers = [10.0.0.213:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = false
interceptor.classes = []
internal.auto.downgrade.txn.commit = false
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 127000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class com.example.productreviews.KafkaJsonReviewDataSerializer
13:59:03.153 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Starting Kafka producer I/O thread.
13:59:03.155 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.7.1
13:59:03.156 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 61dbce85d0d41457
13:59:03.156 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1660157943153
13:59:03.156 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initialize connection to node 10.0.0.213:9092 (id: -1 rack: null) for sending metadata request
13:59:03.158 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating connection to node 10.0.0.213:9092 (id: -1 rack: null) using address /10.0.0.213
13:59:03.159 [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Kafka producer started
13:59:03.177 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.common.network.Selector - [Producer clientId=producer-1] Created socket with SO_RCVBUF = 33304, SO_SNDBUF = 131768, SO_TIMEOUT = 0 to node -1
13:59:03.498 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Completed connection to node -1. Fetching API versions.
13:59:03.498 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node -1.
13:59:03.516 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=producer-1, correlationId=0) and timeout 30000 to node -1: {client_software_name=apache-kafka-java,client_software_version=2.7.1,_tagged_fields={}}
13:59:03.570 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received API_VERSIONS response from node -1 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=producer-1, correlationId=0): org.apache.kafka.common.requests.ApiVersionsResponse@43723aac
13:59:03.572 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Recorded API versions for node -1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 12 [usable: 12], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 7 [usable: 7], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 7 [usable: 7], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 6 [usable: 6], DeleteTopics(20): 0 to 5 [usable: 5], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 2 [usable: 2], AddOffsetsToTxn(25): 0 to 2 [usable: 2], EndTxn(26): 0 to 2 [usable: 2], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 3 [usable: 3], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 2 [usable: 2], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 [usable: 0], AlterClientQuotas(49): 0 [usable: 0], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterIsr(56): 0 [usable: 0], UpdateFeatures(57): 0 [usable: 0])
13:59:03.573 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='quickstart-events')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node 10.0.0.213:9092 (id: -1 rack: null)
13:59:03.573 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=9, clientId=producer-1, correlationId=1) and timeout 30000 to node -1: {topics=[{name=quickstart-events,_tagged_fields={}}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false,_tagged_fields={}}
13:59:03.590 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received METADATA response from node -1 for request with header RequestHeader(apiKey=METADATA, apiVersion=9, clientId=producer-1, correlationId=1): org.apache.kafka.common.requests.MetadataResponse@33b6179d
13:59:03.593 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {quickstart-events=LEADER_NOT_AVAILABLE}
13:59:03.594 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Requesting metadata update for topic quickstart-events due to error LEADER_NOT_AVAILABLE
13:59:03.594 [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Cluster ID: Hvx4aOvuRY2uKlPYRypFdA
13:59:03.594 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='Hvx4aOvuRY2uKlPYRypFdA', nodes={1=10.0.0.213:9092 (id: 1 rack: null), 2=10.0.0.213:9093 (id: 2 rack: null), 3=10.0.0.213:9094 (id: 3 rack: null)}, partitions=[], controller=10.0.0.213:9092 (id: 1 rack: null)}
13:59:03.689 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initialize connection to node 10.0.0.213:9093 (id: 2 rack: null) for sending metadata request
13:59:03.689 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating connection to node 10.0.0.213:9093 (id: 2 rack: null) using address /10.0.0.213
13:59:03.693 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.common.network.Selector - [Producer clientId=producer-1] Created socket with SO_RCVBUF = 33304, SO_SNDBUF = 131768, SO_TIMEOUT = 0 to node 2
13:59:03.693 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Completed connection to node 2. Fetching API versions.
13:59:03.693 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node 2.
13:59:03.693 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=producer-1, correlationId=2) and timeout 30000 to node 2: {client_software_name=apache-kafka-java,client_software_version=2.7.1,_tagged_fields={}}
13:59:03.701 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received API_VERSIONS response from node 2 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=producer-1, correlationId=2): org.apache.kafka.common.requests.ApiVersionsResponse@734c852
13:59:03.702 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Recorded API versions for node 2: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 12 [usable: 12], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 7 [usable: 7], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 7 [usable: 7], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 6 [usable: 6], DeleteTopics(20): 0 to 5 [usable: 5], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 2 [usable: 2], AddOffsetsToTxn(25): 0 to 2 [usable: 2], EndTxn(26): 0 to 2 [usable: 2], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 3 [usable: 3], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 2 [usable: 2], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 [usable: 0], AlterClientQuotas(49): 0 [usable: 0], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterIsr(56): 0 [usable: 0], UpdateFeatures(57): 0 [usable: 0])
13:59:03.702 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='quickstart-events')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node 10.0.0.213:9093 (id: 2 rack: null)
13:59:03.702 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=9, clientId=producer-1, correlationId=3) and timeout 30000 to node 2: {topics=[{name=quickstart-events,_tagged_fields={}}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false,_tagged_fields={}}
13:59:03.710 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received METADATA response from node 2 for request with header RequestHeader(apiKey=METADATA, apiVersion=9, clientId=producer-1, correlationId=3): org.apache.kafka.common.requests.MetadataResponse@62878f0f
13:59:03.710 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Updating last seen epoch for partition quickstart-events-0 from null to epoch 0 from new metadata
13:59:03.716 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Updated cluster metadata updateVersion 3 to MetadataCache{clusterId='Hvx4aOvuRY2uKlPYRypFdA', nodes={1=10.0.0.213:9092 (id: 1 rack: null), 2=10.0.0.213:9093 (id: 2 rack: null), 3=10.0.0.213:9094 (id: 3 rack: null)}, partitions=[PartitionMetadata(error=NONE, partition=quickstart-events-0, leader=Optional[1], leaderEpoch=Optional[0], replicas=1, isr=1, offlineReplicas=)], controller=10.0.0.213:9092 (id: 1 rack: null)}
13:59:04.009 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating connection to node 10.0.0.213:9092 (id: 1 rack: null) using address /10.0.0.213
13:59:04.017 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.common.network.Selector - [Producer clientId=producer-1] Created socket with SO_RCVBUF = 33304, SO_SNDBUF = 131768, SO_TIMEOUT = 0 to node 1
13:59:04.017 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Completed connection to node 1. Fetching API versions.
13:59:04.017 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node 1.
13:59:04.017 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=producer-1, correlationId=4) and timeout 30000 to node 1: {client_software_name=apache-kafka-java,client_software_version=2.7.1,_tagged_fields={}}
13:59:04.032 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received API_VERSIONS response from node 1 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=producer-1, correlationId=4): org.apache.kafka.common.requests.ApiVersionsResponse@313d30c4
13:59:04.033 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Recorded API versions for node 1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 12 [usable: 12], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 7 [usable: 7], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 7 [usable: 7], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 6 [usable: 6], DeleteTopics(20): 0 to 5 [usable: 5], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 2 [usable: 2], AddOffsetsToTxn(25): 0 to 2 [usable: 2], EndTxn(26): 0 to 2 [usable: 2], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 3 [usable: 3], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 2 [usable: 2], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 [usable: 0], AlterClientQuotas(49): 0 [usable: 0], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterIsr(56): 0 [usable: 0], UpdateFeatures(57): 0 [usable: 0])
13:59:04.040 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=8, clientId=producer-1, correlationId=5) and timeout 30000 to node 1: {acks=1,timeout=30000,partitionSizes=[quickstart-events-0=274]}
13:59:04.053 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received PRODUCE response from node 1 for request with header RequestHeader(apiKey=PRODUCE, apiVersion=8, clientId=producer-1, correlationId=5): org.apache.kafka.common.requests.ProduceResponse@1f518433
13:59:09.017 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=8, clientId=producer-1, correlationId=6) and timeout 30000 to node 1: {acks=1,timeout=30000,partitionSizes=[quickstart-events-0=274]}
13:59:09.027 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received PRODUCE response from node 1 for request with header RequestHeader(apiKey=PRODUCE, apiVersion=8, clientId=producer-1, correlationId=6): org.apache.kafka.common.requests.ProduceResponse@3d980d99
Message sent successfully
13:59:14.018 [main] INFO org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
13:59:14.018 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
13:59:14.027 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Shutdown of Kafka producer I/O thread has completed.
13:59:14.027 [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed
13:59:14.027 [main] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter
13:59:14.028 [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed
13:59:14.028 [main] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.producer for producer-1 unregistered
13:59:14.028 [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Kafka producer has been closed
Process finished with exit code 0
Updating the docker compose resolved the issue and message was sent
pxchek
commented
2 years ago The above message is sent successfully and persisted in the kafka broker running inside a docker container
sh-4.4$ pwd
/var/lib/kafka/data
sh-4.4$ cd quickstart-events-0/
sh-4.4$ cat 00000000000000000000.log
?D????ߤ??ߤ????????????????{"reviewerID":"530-4953590-345","asin":"784574747","reviewerName":"J. Smith","helpful":[2,3],"reviewText":"Review Text","overall":5.0,"summary":null,"unixReviewTime":1252800000,"reviewTime":"09 13, 2021"}??Ψ???S???S????????????????{"reviewerID":"530-4953590-345","asin":"784574747","reviewerName":"J. Smith","helpful":[2,3],"reviewText":"Review Text","overall":5.0,"summary":null,"unixReviewTime":1252800000,"reviewTime":"09 13, 2021"}sh-4.4$
sh-4.4$