[2019-07-09 22:20:12,331] INFO Server environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,346] INFO Server environment:host.name=asf922.gq1.ygridcore.net (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,348] INFO Server environment:java.version=11.0.1 (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,349] INFO Server environment:java.vendor=Oracle Corporation (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,349] INFO Server environment:java.home=/usr/local/asfpackages/java/jdk-11.0.1 (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,350] INFO Server environment:java.class.path=/home/jenkins/.gradle/caches/5.4.1/workerMain/gradle-worker.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/classes/java/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/resources/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/classes/java/main:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/resources/main:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/clients/build/classes/java/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/clients/build/resources/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/classes/java/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/classes/scala/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/resources/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/json/build/libs/connect-json-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/transforms/build/libs/connect-transforms-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/api/build/libs/connect-api-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/tools/build/libs/kafka-tools-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/libs/kafka_2.13-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/log4j-appender/build/libs/kafka-log4j-appender-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/clients/build/libs/kafka-clients-2.4.0-SNAPSHOT.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.26/12f5c685b71c3027fd28bcf90528ec4ec74bf818/slf4j-log4j12-1.7.26.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.yammer.metrics/metrics-core/2.2.0/f82c035cfa786d3cbec362c38c22a5f5b1bc8724/metrics-core-2.2.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.typesafe.scala-logging/scala-logging_2.13/3.9.2/6986314976f55419819ca7ae9f9d077ba070fe42/scala-logging_2.13-3.9.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.zookeeper/zookeeper/3.4.14/c114c1e1c8172a7cd3f6ae39209a635f7a06c1a1/zookeeper-3.4.14.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.26/77100a62c2e6f04b53977b9f541044d7d722693d/slf4j-api-1.7.26.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.jaxrs/jackson-jaxrs-json-provider/2.9.9/7deb5d0d335265ace2a9048c8d6e203b588a1724/jackson-jaxrs-json-provider-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.containers/jersey-container-servlet/2.28/3b77ac98ef980f4f57779a7edbbd5622f86dfc7b/jersey-container-servlet-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.inject/jersey-hk2/2.28/34903847d20c2833e1699dccd87bfab5d9fde9ed/jersey-hk2-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.xml.bind/jaxb-api/2.3.0/99f802e0cb3e953ba3d6e698795c4aeb98d37c48/jaxb-api-2.3.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.activation/activation/1.1.1/485de3a253e23f645037828c07f1d7f1af40763a/activation-1.1.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-servlet/9.4.18.v20190429/290f7a88f351950d51ebc9fb4a794752c62d7de5/jetty-servlet-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-security/9.4.18.v20190429/1aceff3608ca1b223bfd275a497797cfe675ef4/jetty-security-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-server/9.4.18.v20190429/b76ef50e04635f11d4d43bc6ccb7c4482a8384f0/jetty-server-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-servlets/9.4.18.v20190429/e5d174950a44c8f93e27cc2528eff5a6b55da2f3/jetty-servlets-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-client/9.4.18.v20190429/e5d7bd53f2f3ae46354efa56beca2dc505258e92/jetty-client-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.reflections/reflections/0.9.11/4c686033d918ec1727e329b7222fcb020152e32b/reflections-0.9.11.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.maven/maven-artifact/3.6.1/4603471881d2f033b80c13ada7a31f56df7435e5/maven-artifact-3.6.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-easymock/2.0.2/2f40f5319f9da2a6848cdd5fe2bfd834b76f0f46/powermock-api-easymock-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.easymock/easymock/4.0.2/f74aebbe02f5051bea31c0dbc5df5202a59e0b78/easymock-4.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4/2.0.2/5b29faa1283332f1368cfa87d688e47ae75b7368/powermock-module-junit4-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4-common/2.0.2/1a2c7b5533a4e938b94df4da704ff997fe7a308d/powermock-module-junit4-common-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/junit/junit/4.13-beta-2/2470c41ebd351f7edceac9eea7c414ac847a154/junit-4.13-beta-2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.mockito/mockito-core/2.27.0/835fc3283b481f4758b8ef464cd560c649c08b00/mockito-core-2.27.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpclient/4.5.8/c27c9d6f15435dc2b6947112027b418b0eef32b9/httpclient-4.5.8.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.ws.rs/javax.ws.rs-api/2.1.1/d3466bc9321fe84f268a1adb3b90373fc14b0eb5/javax.ws.rs-api-2.1.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.github.luben/zstd-jni/1.4.0-1/8cc7f9b0f2bd53ef3bd0e38fccc678691f983474/zstd-jni-1.4.0-1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.lz4/lz4-java/1.6.0/b49e2b422a5b7145ba7aa0c3f60c13664a5c5acf/lz4-java-1.6.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.1.7.3/241bb74a1eb37d68a4e324a4bc3865427de0a62d/snappy-java-1.1.7.3.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.sourceforge.argparse4j/argparse4j/0.7.0/6f0621d0c3888de39e0f06d01f37ba53a798e657/argparse4j-0.7.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.datatype/jackson-datatype-jdk8/2.9.9/4b04126963103216c9c43b0f34bbc36315654204/jackson-datatype-jdk8-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.jaxrs/jackson-jaxrs-base/2.9.9/fc33bfa121b746db0f9fb8f36ed2e6682a1c1dd0/jackson-jaxrs-base-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.module/jackson-module-jaxb-annotations/2.9.9/52fb643de81a60839750013a520f26b6259ddeff/jackson-module-jaxb-annotations-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.module/jackson-module-scala_2.13/2.9.9/cd62de6f8b71e6f51db1f9ef53a3f99dc281c2f5/jackson-module-scala_2.13-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.dataformat/jackson-dataformat-csv/2.9.9/32130e6ec2c9116e3a03a92a4c04f46c5c0ffe03/jackson-dataformat-csv-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.module/jackson-module-paranamer/2.9.9/a99b9809c0d45072ca9911eead00ecee946ba06a/jackson-module-paranamer-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-databind/2.9.9/d6eb9817d9c7289a91f043ac5ee02a6b3cc86238/jackson-databind-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.containers/jersey-container-servlet-core/2.28/35fffcabd4be102800ee788f7809c7c713620d61/jersey-container-servlet-core-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.core/jersey-server/2.28/bc94aedb9d4d82bd23f8b78a345868b11f52abb9/jersey-server-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.core/jersey-client/2.28/cdde34d5980fa498a922a310140e0dd0a69c2e67/jersey-client-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.media/jersey-media-jaxb/2.28/dcd803fe1c19467c913a2638a6635d4915695867/jersey-media-jaxb-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.core/jersey-common/2.28/ec54308041b593386edf8eb505146907dbdc88e6/jersey-common-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/jakarta.ws.rs/jakarta.ws.rs-api/2.1.5/e45d7f94d7406489755d911e63c216b4a3210374/jakarta.ws.rs-api-2.1.5.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/hk2-locator/2.5.0/4a0921428fef1e691cb9df035d44608b21af95a7/hk2-locator-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.servlet/javax.servlet-api/3.1.0/3cd63d075497751784b2fa84be59432f4905bf7c/javax.servlet-api-3.1.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-http/9.4.18.v20190429/c2e73db2db5c369326b717da71b6587b3da11e0e/jetty-http-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-io/9.4.18.v20190429/844af5efe58ab23fd0166a796efef123f4cb06b0/jetty-io-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-continuation/9.4.18.v20190429/3c421a3be5be5805e32b1a7f9c6046526524181d/jetty-continuation-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-util/9.4.18.v20190429/13e6148bfda7ae511f69ae7e5e3ea898bc9b0e33/jetty-util-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/20.0/89507701249388e1ed5ddcf8c41f4ce1be7831ef/guava-20.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-support/2.0.2/609f2960a138e376df8700fa44e26cabfe960f45/powermock-api-support-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-core/2.0.2/d8b5e02b891e16d8be9e6d19bfeacc987168426d/powermock-core-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.javassist/javassist/3.24.0-GA/d7466fc2e3af7c023e95c510f06448ad29b225b3/javassist-3.24.0-GA.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.codehaus.plexus/plexus-utils/3.2.0/d69e11d69dfce0c964587ab97b559187b3c27a6f/plexus-utils-3.2.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-lang3/3.8.1/6505a72a097d9270f7a9e7bf42c4238283247755/commons-lang3-3.8.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-reflect/2.0.2/79df0e5792fba38278b90f9e22617f5684313017/powermock-reflect-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.objenesis/objenesis/3.0.1/11cfac598df9dc48bb9ed9357ed04212694b7808/objenesis-3.0.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/cglib/cglib-nodep/3.2.9/27ca91ebc2b82f844e62a7ba8c2c1fdf9b84fa80/cglib-nodep-3.2.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.bytebuddy/byte-buddy/1.9.10/211a2b4d3df1eeef2a6cacf78d74a1f725e7a840/byte-buddy-1.9.10.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.bytebuddy/byte-buddy-agent/1.9.10/9674aba5ee793e54b864952b001166848da0f26b/byte-buddy-agent-1.9.10.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.4.11/de748cf874e4e193b42eceea9fe5574fabb9d4df/httpcore-4.4.11.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/commons-logging/commons-logging/1.2/4bfc12adfe4842bf07b657f0369c4cb522955686/commons-logging-1.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.11/3acb4705652e16236558f0f4f2192cc33c3bd189/commons-codec-1.11.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.sf.jopt-simple/jopt-simple/5.0.4/4fdac2fbe92dfad86aa6e9301736f6b4342a3f5c/jopt-simple-5.0.4.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang.modules/scala-collection-compat_2.13/2.1.0/68608bcb7587e4c36f0e0e3fd04cc1119445af6c/scala-collection-compat_2.13-2.1.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang.modules/scala-java8-compat_2.13/0.9.0/cecd75f8db95161dda4b6ea226c964f6df4a6d8e/scala-java8-compat_2.13-0.9.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang/scala-reflect/2.13.0/2dbe07b0369dbf00a098b7925b2afca016f124b0/scala-reflect-2.13.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang/scala-library/2.13.0/e988ea597113786768900f1c260c694a2ae32a42/scala-library-2.13.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/log4j/log4j/1.2.17/5af35056b4d257e4b64b9e8069c0746e8b08629f/log4j-1.2.17.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-annotations/2.9.9/2ea299c145207161c212e28abbc8f513fa245940/jackson-annotations-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-core/2.9.9/bfff5af9fb8347d26bbb7959cb9b4fe9a2b0ca5e/jackson-core-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/hk2-api/2.5.0/4620ab411f8225cbf6f89fedf67634bb2277d209/hk2-api-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/hk2-utils/2.5.0/695d0a3aeb28db5cf42ae4d456f1b605bd0f3d0f/hk2-utils-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2.external/jakarta.inject/2.5.0/8f99415464ec2dd6afbdd4e9db9249c993065150/jakarta.inject-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/jakarta.annotation/jakarta.annotation-api/1.3.4/a858ec3f0ebd2b8d855c1ddded2cde9b381b0517/jakarta.annotation-api-1.3.4.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/osgi-resource-locator/1.0.1/4ed2b2d4738aed5786cfa64cba5a332779c4c708/osgi-resource-locator-1.0.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.validation/validation-api/2.0.1.Final/cb855558e6271b1b32e716d24cb85c7f583ce09e/validation-api-2.0.1.Final.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2.external/aopalliance-repackaged/2.5.0/2fa68c05f54f1bba9559dd571eb81959081f1895/aopalliance-repackaged-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.github.spotbugs/spotbugs-annotations/3.1.9/2ef5127efcc1a899aab8c66d449a631c9a99c469/spotbugs-annotations-3.1.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.yetus/audience-annotations/0.5.0/55762d3191a8d6610ef46d11e8cb70c7667342a3/audience-annotations-0.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.8/619eba74c19ccf1da8ebec97a2d7f8ba05773dd6/paranamer-2.8.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/3.0.2/25ea2e8b0c338a877313bd4672d3fe056ea78f0d/jsr305-3.0.2.jar (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,354] INFO Server environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,354] INFO Server environment:java.io.tmpdir=/tmp (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,355] INFO Server environment:java.compiler= (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,355] INFO Server environment:os.name=Linux (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,356] INFO Server environment:os.arch=amd64 (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,356] INFO Server environment:os.version=4.4.0-138-generic (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,357] INFO Server environment:user.name=jenkins (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,357] INFO Server environment:user.home=/home/jenkins (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,357] INFO Server environment:user.dir=/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime (org.apache.zookeeper.server.ZooKeeperServer:100) [2019-07-09 22:20:12,403] INFO Created server with tickTime 800 minSessionTimeout 1600 maxSessionTimeout 16000 datadir /tmp/kafka-18051298677163705621/version-2 snapdir /tmp/kafka-15390004324978735867/version-2 (org.apache.zookeeper.server.ZooKeeperServer:174) [2019-07-09 22:20:12,429] INFO binding to port /127.0.0.1:0 (org.apache.zookeeper.server.NIOServerCnxnFactory:89) [2019-07-09 22:20:13,580] INFO Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,581] INFO Client environment:host.name=asf922.gq1.ygridcore.net (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,582] INFO Client environment:java.version=11.0.1 (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,582] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,583] INFO Client environment:java.home=/usr/local/asfpackages/java/jdk-11.0.1 (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,583] INFO Client environment:java.class.path=/home/jenkins/.gradle/caches/5.4.1/workerMain/gradle-worker.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/classes/java/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/resources/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/classes/java/main:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime/build/resources/main:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/clients/build/classes/java/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/clients/build/resources/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/classes/java/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/classes/scala/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/resources/test:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/json/build/libs/connect-json-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/transforms/build/libs/connect-transforms-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/api/build/libs/connect-api-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/tools/build/libs/kafka-tools-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/core/build/libs/kafka_2.13-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/log4j-appender/build/libs/kafka-log4j-appender-2.4.0-SNAPSHOT.jar:/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/clients/build/libs/kafka-clients-2.4.0-SNAPSHOT.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.26/12f5c685b71c3027fd28bcf90528ec4ec74bf818/slf4j-log4j12-1.7.26.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.yammer.metrics/metrics-core/2.2.0/f82c035cfa786d3cbec362c38c22a5f5b1bc8724/metrics-core-2.2.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.typesafe.scala-logging/scala-logging_2.13/3.9.2/6986314976f55419819ca7ae9f9d077ba070fe42/scala-logging_2.13-3.9.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.zookeeper/zookeeper/3.4.14/c114c1e1c8172a7cd3f6ae39209a635f7a06c1a1/zookeeper-3.4.14.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.26/77100a62c2e6f04b53977b9f541044d7d722693d/slf4j-api-1.7.26.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.jaxrs/jackson-jaxrs-json-provider/2.9.9/7deb5d0d335265ace2a9048c8d6e203b588a1724/jackson-jaxrs-json-provider-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.containers/jersey-container-servlet/2.28/3b77ac98ef980f4f57779a7edbbd5622f86dfc7b/jersey-container-servlet-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.inject/jersey-hk2/2.28/34903847d20c2833e1699dccd87bfab5d9fde9ed/jersey-hk2-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.xml.bind/jaxb-api/2.3.0/99f802e0cb3e953ba3d6e698795c4aeb98d37c48/jaxb-api-2.3.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.activation/activation/1.1.1/485de3a253e23f645037828c07f1d7f1af40763a/activation-1.1.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-servlet/9.4.18.v20190429/290f7a88f351950d51ebc9fb4a794752c62d7de5/jetty-servlet-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-security/9.4.18.v20190429/1aceff3608ca1b223bfd275a497797cfe675ef4/jetty-security-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-server/9.4.18.v20190429/b76ef50e04635f11d4d43bc6ccb7c4482a8384f0/jetty-server-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-servlets/9.4.18.v20190429/e5d174950a44c8f93e27cc2528eff5a6b55da2f3/jetty-servlets-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-client/9.4.18.v20190429/e5d7bd53f2f3ae46354efa56beca2dc505258e92/jetty-client-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.reflections/reflections/0.9.11/4c686033d918ec1727e329b7222fcb020152e32b/reflections-0.9.11.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.maven/maven-artifact/3.6.1/4603471881d2f033b80c13ada7a31f56df7435e5/maven-artifact-3.6.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-easymock/2.0.2/2f40f5319f9da2a6848cdd5fe2bfd834b76f0f46/powermock-api-easymock-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.easymock/easymock/4.0.2/f74aebbe02f5051bea31c0dbc5df5202a59e0b78/easymock-4.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4/2.0.2/5b29faa1283332f1368cfa87d688e47ae75b7368/powermock-module-junit4-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4-common/2.0.2/1a2c7b5533a4e938b94df4da704ff997fe7a308d/powermock-module-junit4-common-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/junit/junit/4.13-beta-2/2470c41ebd351f7edceac9eea7c414ac847a154/junit-4.13-beta-2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.mockito/mockito-core/2.27.0/835fc3283b481f4758b8ef464cd560c649c08b00/mockito-core-2.27.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpclient/4.5.8/c27c9d6f15435dc2b6947112027b418b0eef32b9/httpclient-4.5.8.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.ws.rs/javax.ws.rs-api/2.1.1/d3466bc9321fe84f268a1adb3b90373fc14b0eb5/javax.ws.rs-api-2.1.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.github.luben/zstd-jni/1.4.0-1/8cc7f9b0f2bd53ef3bd0e38fccc678691f983474/zstd-jni-1.4.0-1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.lz4/lz4-java/1.6.0/b49e2b422a5b7145ba7aa0c3f60c13664a5c5acf/lz4-java-1.6.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.1.7.3/241bb74a1eb37d68a4e324a4bc3865427de0a62d/snappy-java-1.1.7.3.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.sourceforge.argparse4j/argparse4j/0.7.0/6f0621d0c3888de39e0f06d01f37ba53a798e657/argparse4j-0.7.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.datatype/jackson-datatype-jdk8/2.9.9/4b04126963103216c9c43b0f34bbc36315654204/jackson-datatype-jdk8-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.jaxrs/jackson-jaxrs-base/2.9.9/fc33bfa121b746db0f9fb8f36ed2e6682a1c1dd0/jackson-jaxrs-base-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.module/jackson-module-jaxb-annotations/2.9.9/52fb643de81a60839750013a520f26b6259ddeff/jackson-module-jaxb-annotations-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.module/jackson-module-scala_2.13/2.9.9/cd62de6f8b71e6f51db1f9ef53a3f99dc281c2f5/jackson-module-scala_2.13-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.dataformat/jackson-dataformat-csv/2.9.9/32130e6ec2c9116e3a03a92a4c04f46c5c0ffe03/jackson-dataformat-csv-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.module/jackson-module-paranamer/2.9.9/a99b9809c0d45072ca9911eead00ecee946ba06a/jackson-module-paranamer-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-databind/2.9.9/d6eb9817d9c7289a91f043ac5ee02a6b3cc86238/jackson-databind-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.containers/jersey-container-servlet-core/2.28/35fffcabd4be102800ee788f7809c7c713620d61/jersey-container-servlet-core-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.core/jersey-server/2.28/bc94aedb9d4d82bd23f8b78a345868b11f52abb9/jersey-server-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.core/jersey-client/2.28/cdde34d5980fa498a922a310140e0dd0a69c2e67/jersey-client-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.media/jersey-media-jaxb/2.28/dcd803fe1c19467c913a2638a6635d4915695867/jersey-media-jaxb-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.jersey.core/jersey-common/2.28/ec54308041b593386edf8eb505146907dbdc88e6/jersey-common-2.28.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/jakarta.ws.rs/jakarta.ws.rs-api/2.1.5/e45d7f94d7406489755d911e63c216b4a3210374/jakarta.ws.rs-api-2.1.5.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/hk2-locator/2.5.0/4a0921428fef1e691cb9df035d44608b21af95a7/hk2-locator-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.servlet/javax.servlet-api/3.1.0/3cd63d075497751784b2fa84be59432f4905bf7c/javax.servlet-api-3.1.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-http/9.4.18.v20190429/c2e73db2db5c369326b717da71b6587b3da11e0e/jetty-http-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-io/9.4.18.v20190429/844af5efe58ab23fd0166a796efef123f4cb06b0/jetty-io-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-continuation/9.4.18.v20190429/3c421a3be5be5805e32b1a7f9c6046526524181d/jetty-continuation-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-util/9.4.18.v20190429/13e6148bfda7ae511f69ae7e5e3ea898bc9b0e33/jetty-util-9.4.18.v20190429.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/20.0/89507701249388e1ed5ddcf8c41f4ce1be7831ef/guava-20.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-support/2.0.2/609f2960a138e376df8700fa44e26cabfe960f45/powermock-api-support-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-core/2.0.2/d8b5e02b891e16d8be9e6d19bfeacc987168426d/powermock-core-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.javassist/javassist/3.24.0-GA/d7466fc2e3af7c023e95c510f06448ad29b225b3/javassist-3.24.0-GA.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.codehaus.plexus/plexus-utils/3.2.0/d69e11d69dfce0c964587ab97b559187b3c27a6f/plexus-utils-3.2.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-lang3/3.8.1/6505a72a097d9270f7a9e7bf42c4238283247755/commons-lang3-3.8.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-reflect/2.0.2/79df0e5792fba38278b90f9e22617f5684313017/powermock-reflect-2.0.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.objenesis/objenesis/3.0.1/11cfac598df9dc48bb9ed9357ed04212694b7808/objenesis-3.0.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/cglib/cglib-nodep/3.2.9/27ca91ebc2b82f844e62a7ba8c2c1fdf9b84fa80/cglib-nodep-3.2.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.bytebuddy/byte-buddy/1.9.10/211a2b4d3df1eeef2a6cacf78d74a1f725e7a840/byte-buddy-1.9.10.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.bytebuddy/byte-buddy-agent/1.9.10/9674aba5ee793e54b864952b001166848da0f26b/byte-buddy-agent-1.9.10.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.4.11/de748cf874e4e193b42eceea9fe5574fabb9d4df/httpcore-4.4.11.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/commons-logging/commons-logging/1.2/4bfc12adfe4842bf07b657f0369c4cb522955686/commons-logging-1.2.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.11/3acb4705652e16236558f0f4f2192cc33c3bd189/commons-codec-1.11.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/net.sf.jopt-simple/jopt-simple/5.0.4/4fdac2fbe92dfad86aa6e9301736f6b4342a3f5c/jopt-simple-5.0.4.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang.modules/scala-collection-compat_2.13/2.1.0/68608bcb7587e4c36f0e0e3fd04cc1119445af6c/scala-collection-compat_2.13-2.1.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang.modules/scala-java8-compat_2.13/0.9.0/cecd75f8db95161dda4b6ea226c964f6df4a6d8e/scala-java8-compat_2.13-0.9.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang/scala-reflect/2.13.0/2dbe07b0369dbf00a098b7925b2afca016f124b0/scala-reflect-2.13.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.scala-lang/scala-library/2.13.0/e988ea597113786768900f1c260c694a2ae32a42/scala-library-2.13.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/log4j/log4j/1.2.17/5af35056b4d257e4b64b9e8069c0746e8b08629f/log4j-1.2.17.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-annotations/2.9.9/2ea299c145207161c212e28abbc8f513fa245940/jackson-annotations-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-core/2.9.9/bfff5af9fb8347d26bbb7959cb9b4fe9a2b0ca5e/jackson-core-2.9.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/hk2-api/2.5.0/4620ab411f8225cbf6f89fedf67634bb2277d209/hk2-api-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/hk2-utils/2.5.0/695d0a3aeb28db5cf42ae4d456f1b605bd0f3d0f/hk2-utils-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2.external/jakarta.inject/2.5.0/8f99415464ec2dd6afbdd4e9db9249c993065150/jakarta.inject-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/jakarta.annotation/jakarta.annotation-api/1.3.4/a858ec3f0ebd2b8d855c1ddded2cde9b381b0517/jakarta.annotation-api-1.3.4.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2/osgi-resource-locator/1.0.1/4ed2b2d4738aed5786cfa64cba5a332779c4c708/osgi-resource-locator-1.0.1.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/javax.validation/validation-api/2.0.1.Final/cb855558e6271b1b32e716d24cb85c7f583ce09e/validation-api-2.0.1.Final.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.glassfish.hk2.external/aopalliance-repackaged/2.5.0/2fa68c05f54f1bba9559dd571eb81959081f1895/aopalliance-repackaged-2.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.github.spotbugs/spotbugs-annotations/3.1.9/2ef5127efcc1a899aab8c66d449a631c9a99c469/spotbugs-annotations-3.1.9.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.yetus/audience-annotations/0.5.0/55762d3191a8d6610ef46d11e8cb70c7667342a3/audience-annotations-0.5.0.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.8/619eba74c19ccf1da8ebec97a2d7f8ba05773dd6/paranamer-2.8.jar:/home/jenkins/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/3.0.2/25ea2e8b0c338a877313bd4672d3fe056ea78f0d/jsr305-3.0.2.jar (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,585] INFO Client environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,586] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,586] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,587] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,587] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,587] INFO Client environment:os.version=4.4.0-138-generic (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,588] INFO Client environment:user.name=jenkins (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,588] INFO Client environment:user.home=/home/jenkins (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,589] INFO Client environment:user.dir=/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/connect/runtime (org.apache.zookeeper.ZooKeeper:100) [2019-07-09 22:20:13,592] INFO Initiating client connection, connectString=127.0.0.1:42319 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@2699e190 (org.apache.zookeeper.ZooKeeper:442) [2019-07-09 22:20:13,621] INFO Opening socket connection to server localhost/127.0.0.1:42319. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn:1025) [2019-07-09 22:20:13,625] INFO Socket connection established to localhost/127.0.0.1:42319, initiating session (org.apache.zookeeper.ClientCnxn:879) [2019-07-09 22:20:13,625] INFO Accepted socket connection from /127.0.0.1:43220 (org.apache.zookeeper.server.NIOServerCnxnFactory:222) [2019-07-09 22:20:13,636] INFO Client attempting to establish new session at /127.0.0.1:43220 (org.apache.zookeeper.server.ZooKeeperServer:949) [2019-07-09 22:20:13,642] INFO Creating new log file: log.1 (org.apache.zookeeper.server.persistence.FileTxnLog:216) [2019-07-09 22:20:13,661] INFO Established session 0x105370ed4dd0000 with negotiated timeout 6000 for client /127.0.0.1:43220 (org.apache.zookeeper.server.ZooKeeperServer:694) [2019-07-09 22:20:13,661] INFO Session establishment complete on server localhost/127.0.0.1:42319, sessionid = 0x105370ed4dd0000, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn:1299) [2019-07-09 22:20:13,780] INFO Got user-level KeeperException when processing sessionid:0x105370ed4dd0000 type:create cxid:0x2 zxid:0x3 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers (org.apache.zookeeper.server.PrepRequestProcessor:653) [2019-07-09 22:20:13,789] INFO Got user-level KeeperException when processing sessionid:0x105370ed4dd0000 type:create cxid:0x6 zxid:0x7 txntype:-1 reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config (org.apache.zookeeper.server.PrepRequestProcessor:653) [2019-07-09 22:20:13,795] INFO Got user-level KeeperException when processing sessionid:0x105370ed4dd0000 type:create cxid:0x9 zxid:0xa txntype:-1 reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin (org.apache.zookeeper.server.PrepRequestProcessor:653) [2019-07-09 22:20:14,408] INFO Got user-level KeeperException when processing sessionid:0x105370ed4dd0000 type:create cxid:0x15 zxid:0x15 txntype:-1 reqpath:n/a Error Path:/cluster Error:KeeperErrorCode = NoNode for /cluster (org.apache.zookeeper.server.PrepRequestProcessor:653) [2019-07-09 22:20:14,425] WARN No meta.properties file under dir /tmp/junit6422342738388876143/junit8548265229818228915/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2019-07-09 22:20:15,728] WARN No meta.properties file under dir /tmp/junit6422342738388876143/junit8548265229818228915/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2019-07-09 22:20:16,519] INFO Got user-level KeeperException when processing sessionid:0x105370ed4dd0000 type:multi cxid:0x32 zxid:0x1c txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor:596) [2019-07-09 22:20:16,548] INFO Kafka version: 2.4.0-SNAPSHOT (org.apache.kafka.common.utils.AppInfoParser:117) [2019-07-09 22:20:16,549] INFO Kafka commitId: 84d232db55222799 (org.apache.kafka.common.utils.AppInfoParser:118) [2019-07-09 22:20:16,549] INFO Kafka startTimeMs: 1562710811989 (org.apache.kafka.common.utils.AppInfoParser:119) [2019-07-09 22:20:16,569] INFO ProducerConfig values: acks = 1 batch.size = 16384 bootstrap.servers = [localhost:34429] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.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 send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig:347) [2019-07-09 22:20:16,639] INFO Kafka version: 2.4.0-SNAPSHOT (org.apache.kafka.common.utils.AppInfoParser:117) [2019-07-09 22:20:16,640] INFO Kafka commitId: 84d232db55222799 (org.apache.kafka.common.utils.AppInfoParser:118) [2019-07-09 22:20:16,640] INFO Kafka startTimeMs: 1562710816639 (org.apache.kafka.common.utils.AppInfoParser:119) [2019-07-09 22:20:16,641] INFO Starting Connect cluster 'connect-cluster' with 3 workers (org.apache.kafka.connect.util.clusters.EmbeddedConnectCluster:208) [2019-07-09 22:20:16,648] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed:90) [2019-07-09 22:20:16,771] INFO [Producer clientId=producer-1] Cluster ID: mX30dVC0RJq767wWqqOoIQ (org.apache.kafka.clients.Metadata:266) [2019-07-09 22:20:19,114] DEBUG Skipping class org.apache.kafka.connect.runtime.WorkerConnectorTest$TestConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,140] DEBUG Skipping class org.apache.kafka.connect.runtime.distributed.DistributedHerderTest$BogusSourceConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,141] DEBUG Skipping class org.apache.kafka.connect.runtime.standalone.StandaloneHerderTest$BogusSourceConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,142] DEBUG Skipping class org.apache.kafka.connect.source.SourceConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,142] DEBUG Skipping class org.apache.kafka.connect.runtime.standalone.StandaloneHerderTest$BogusSinkConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,144] DEBUG Skipping class org.apache.kafka.connect.sink.SinkConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,144] DEBUG Skipping class org.apache.kafka.connect.runtime.ConnectorConfigTest$TestConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,145] DEBUG Skipping class org.apache.kafka.connect.runtime.AbstractHerderTest$BogusSourceConnector as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,154] DEBUG Skipping class org.apache.kafka.connect.converters.NumberConverter as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,156] DEBUG Skipping class org.apache.kafka.connect.converters.NumberConverter as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,184] DEBUG Skipping class org.apache.kafka.connect.transforms.ExtractField as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,184] DEBUG Skipping class org.apache.kafka.connect.transforms.MaskField as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,185] DEBUG Skipping class org.apache.kafka.connect.transforms.Cast as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,186] DEBUG Skipping class org.apache.kafka.connect.transforms.InsertField as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,186] DEBUG Skipping class org.apache.kafka.connect.transforms.HoistField as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,187] DEBUG Skipping class org.apache.kafka.connect.transforms.ReplaceField as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,187] DEBUG Skipping class org.apache.kafka.connect.transforms.TimestampConverter as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,188] DEBUG Skipping class org.apache.kafka.connect.transforms.SetSchemaMetadata as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,188] DEBUG Skipping class org.apache.kafka.connect.transforms.Flatten as it is not concrete implementation (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:333) [2019-07-09 22:20:19,199] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@2c13da15 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245) [2019-07-09 22:20:19,200] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,200] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,201] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,201] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,202] INFO Added plugin 'org.apache.kafka.connect.integration.MonitorableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,202] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,202] INFO Added plugin 'org.apache.kafka.connect.runtime.TestSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,203] INFO Added plugin 'org.apache.kafka.connect.runtime.WorkerTest$WorkerTestConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,203] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,204] INFO Added plugin 'org.apache.kafka.connect.integration.MonitorableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,205] INFO Added plugin 'org.apache.kafka.connect.runtime.TestSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,205] INFO Added plugin 'org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResourceTest$ConnectorPluginsResourceTestConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,206] INFO Added plugin 'org.apache.kafka.connect.runtime.WorkerTest$TestConfigurableConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,206] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,206] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,207] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,207] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,207] INFO Added plugin 'org.apache.kafka.connect.runtime.WorkerTest$TestConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,208] INFO Added plugin 'org.apache.kafka.connect.runtime.ErrorHandlingTaskTest$FaultyConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,208] INFO Added plugin 'org.apache.kafka.connect.runtime.isolation.PluginsTest$TestInternalConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,209] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,209] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,210] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,210] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,211] INFO Added plugin 'org.apache.kafka.connect.runtime.isolation.PluginsTest$TestConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,211] INFO Added plugin 'org.apache.kafka.connect.runtime.isolation.PluginsTest$TestHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,212] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,212] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,213] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,213] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174) [2019-07-09 22:20:19,213] INFO Added plugin 'org.apache.kafka.connect.integration.ErrorHandlingIntegrationT ...[truncated 74020721 chars]... s=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,916] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,916] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32231}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32231, keySchema=Schema{STRING}, value=value-simple-conn-0-32231, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,916] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,916] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32232}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32232, keySchema=Schema{STRING}, value=value-simple-conn-0-32232, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,916] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,916] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32233}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32233, keySchema=Schema{STRING}, value=value-simple-conn-0-32233, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,916] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,917] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32235}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32235, keySchema=Schema{STRING}, value=value-simple-conn-0-32235, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,917] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,917] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32239}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32239, keySchema=Schema{STRING}, value=value-simple-conn-0-32239, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,917] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,917] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32243}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32243, keySchema=Schema{STRING}, value=value-simple-conn-0-32243, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,917] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,918] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32250}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32250, keySchema=Schema{STRING}, value=value-simple-conn-0-32250, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,918] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,918] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32255}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32255, keySchema=Schema{STRING}, value=value-simple-conn-0-32255, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,918] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,918] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32256}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32256, keySchema=Schema{STRING}, value=value-simple-conn-0-32256, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,918] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,918] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32260}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32260, keySchema=Schema{STRING}, value=value-simple-conn-0-32260, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,919] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,919] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32263}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32263, keySchema=Schema{STRING}, value=value-simple-conn-0-32263, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,919] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,919] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32264}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32264, keySchema=Schema{STRING}, value=value-simple-conn-0-32264, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,919] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,919] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32265}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32265, keySchema=Schema{STRING}, value=value-simple-conn-0-32265, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,919] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,920] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32267}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32267, keySchema=Schema{STRING}, value=value-simple-conn-0-32267, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,920] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,920] INFO shutting down (org.apache.zookeeper.server.ZooKeeperServer:502) [2019-07-09 22:21:19,920] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32272}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32272, keySchema=Schema{STRING}, value=value-simple-conn-0-32272, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,920] INFO Shutting down (org.apache.zookeeper.server.SessionTrackerImpl:226) [2019-07-09 22:21:19,920] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,921] INFO Shutting down (org.apache.zookeeper.server.PrepRequestProcessor:769) [2019-07-09 22:21:19,921] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32273}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32273, keySchema=Schema{STRING}, value=value-simple-conn-0-32273, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,921] INFO PrepRequestProcessor exited loop! (org.apache.zookeeper.server.PrepRequestProcessor:144) [2019-07-09 22:21:19,921] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,921] INFO Shutting down (org.apache.zookeeper.server.SyncRequestProcessor:208) [2019-07-09 22:21:19,922] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32276}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32276, keySchema=Schema{STRING}, value=value-simple-conn-0-32276, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,922] INFO SyncRequestProcessor exited! (org.apache.zookeeper.server.SyncRequestProcessor:186) [2019-07-09 22:21:19,922] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,923] INFO shutdown of request processor complete (org.apache.zookeeper.server.FinalRequestProcessor:430) [2019-07-09 22:21:19,923] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32277}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32277, keySchema=Schema{STRING}, value=value-simple-conn-0-32277, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,923] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,923] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32278}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32278, keySchema=Schema{STRING}, value=value-simple-conn-0-32278, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,923] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,924] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32280}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32280, keySchema=Schema{STRING}, value=value-simple-conn-0-32280, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,924] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,924] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32281}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32281, keySchema=Schema{STRING}, value=value-simple-conn-0-32281, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,924] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,924] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32283}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32283, keySchema=Schema{STRING}, value=value-simple-conn-0-32283, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,924] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,924] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32287}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32287, keySchema=Schema{STRING}, value=value-simple-conn-0-32287, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,924] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,925] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32288}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32288, keySchema=Schema{STRING}, value=value-simple-conn-0-32288, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,925] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,925] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32292}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32292, keySchema=Schema{STRING}, value=value-simple-conn-0-32292, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,925] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,925] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32297}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32297, keySchema=Schema{STRING}, value=value-simple-conn-0-32297, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,925] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,925] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32298}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32298, keySchema=Schema{STRING}, value=value-simple-conn-0-32298, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,925] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,926] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32301}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32301, keySchema=Schema{STRING}, value=value-simple-conn-0-32301, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,926] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,926] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32306}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32306, keySchema=Schema{STRING}, value=value-simple-conn-0-32306, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,926] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,926] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32309}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32309, keySchema=Schema{STRING}, value=value-simple-conn-0-32309, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,926] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,926] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32312}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32312, keySchema=Schema{STRING}, value=value-simple-conn-0-32312, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,926] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,927] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32313}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32313, keySchema=Schema{STRING}, value=value-simple-conn-0-32313, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,927] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,927] INFO NIOServerCnxn factory exited run method (org.apache.zookeeper.server.NIOServerCnxnFactory:249) [2019-07-09 22:21:19,927] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32315}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32315, keySchema=Schema{STRING}, value=value-simple-conn-0-32315, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,928] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,928] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32316}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32316, keySchema=Schema{STRING}, value=value-simple-conn-0-32316, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,928] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,928] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32318}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32318, keySchema=Schema{STRING}, value=value-simple-conn-0-32318, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,928] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,929] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32321}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32321, keySchema=Schema{STRING}, value=value-simple-conn-0-32321, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,929] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,929] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32323}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32323, keySchema=Schema{STRING}, value=value-simple-conn-0-32323, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,929] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,929] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32331}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32331, keySchema=Schema{STRING}, value=value-simple-conn-0-32331, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,929] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,929] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32332}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32332, keySchema=Schema{STRING}, value=value-simple-conn-0-32332, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,930] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,930] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32338}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32338, keySchema=Schema{STRING}, value=value-simple-conn-0-32338, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,930] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,930] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32339}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32339, keySchema=Schema{STRING}, value=value-simple-conn-0-32339, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,930] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,930] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32340}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32340, keySchema=Schema{STRING}, value=value-simple-conn-0-32340, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,930] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,931] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32341}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32341, keySchema=Schema{STRING}, value=value-simple-conn-0-32341, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,931] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,931] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32343}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32343, keySchema=Schema{STRING}, value=value-simple-conn-0-32343, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,931] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,931] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32345}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32345, keySchema=Schema{STRING}, value=value-simple-conn-0-32345, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331) [2019-07-09 22:21:19,931] ERROR [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} failed to send record to test-topic: (org.apache.kafka.connect.runtime.WorkerSourceTask:330) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:729) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:716) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:278) at java.base/java.lang.Thread.run(Thread.java:834) [2019-07-09 22:21:19,931] DEBUG [simple-conn|task-0] WorkerSourceTask{id=simple-conn-0} Failed record: SourceRecord{sourcePartition={task.id=simple-conn-0}, sourceOffset={saved=32353}} ConnectRecord{topic='test-topic', kafkaPartition=null, key=key-simple-conn-0-32353, keySchema=Schema{STRING}, value=value-simple-conn-0-32353, valueSchema=Schema{STRING}, timestamp=null, headers=ConnectHeaders(headers=)} (org.apache.kafka.connect.runtime.WorkerSourceTask:331)