-
Bug
-
Resolution: Obsolete
-
Major
-
None
-
2.3.0.Final
-
False
-
None
-
False
-
Moderate
In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.
Bug report
For bug reports, provide this information, please:
What Debezium connector do you use and what version?
Debezium Connector for cassandra 4
What is the connector configuration?
the source configuration is as below:
application.properties: |
debezium.sink.type=pulsar
debezium.sink.pulsar.client.serviceUrl={{ $.Values.configuration.pulsar.proxy }}
debezium.sink.pulsar.tenant={{ $.Values.configuration.pulsar.tenant }}
debezium.sink.pulsar.namespace={{ $.Values.configuration.pulsar.tenant }}_cassandra
debezium.source.connector.class=io.debezium.connector.cassandra.Cassandra4Connector
debezium.source.cassandra.hosts=workspace
debezium.source.cassandra.port=9042
debezium.source.cassandra.ssl.enabled=false
debezium.source.cassandra.config=/debezium/data/cassandra.yaml
debezium.source.commit.log.relocation.dir=cassandra/relocdir
debezium.source.http.port=8040
debezium.source.offset.storage.file.filename=data/offsets.dat
debezium.source.offset.flush.interval.ms=60000
debezium.source.schema.whitelist=public
debezium.source.json-with-envelope=false
debezium.source.slot.name={{ $.Values.configuration.pulsar.tenant }}_cassandra
debezium.source.topic.prefix=cassandra
debezium.source.collection=public.dbz_signal
What is the captured database version and mode of depoyment?
(E.g. on-premises, with a specific cloud provider, etc.)
We use Cassandra single node using docker. Version 4.1.2
What behaviour do you expect?
We expect the connector to start and do the cdc
What behaviour do you see?
We get errors:
"timestamp":"2023-06-26T06:38:24.744Z","sequence":178,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.embedded.EmbeddedEngine","level":"ERROR","message":"Error while trying to run connector class 'io.debezium.connector.cassandra.Cassandra4Connector'","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1,"exception":{"refId":1,"exceptionType":"java.lang.NoClassDefFoundError","message":"org/eclipse/jetty/server/Handler","frames":[{"class<span class="code-quote">":"io.debezium.connector.cassandra.CassandraConnectorTask","method":"init","line":47},{"class<span class="code-quote">":"io.debezium.connector.cassandra.Cassandra4ConnectorTask","method":"init","line":12},{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"start","line":69},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"startIfNeededAndPossible","line":244},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"poll","line":153},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":853},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}],"causedBy":{"exception":{"refId":2,"exceptionType":"java.lang.ClassNotFoundException","message":"org.eclipse.jetty.server.Handler","frames":[{"class<span class="code-quote">":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","line":581},{"class<span class="code-quote">":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","line":178},{"class<span class="code-quote">":"java.lang.ClassLoader","method":"loadClass","line":522},{"class<span class="code-quote">":"io.debezium.connector.cassandra.CassandraConnectorTask","method":"init","line":47},{"class<span class="code-quote">":"io.debezium.connector.cassandra.Cassandra4ConnectorTask","method":"init","line":12},{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"start","line":69},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"startIfNeededAndPossible","line":244},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"poll","line":153},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":853},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}]}}}} {"timestamp":"2023-06-26T06:38:24.745Z","sequence":179,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.storage.FileOffsetBackingStore","level":"INFO","message":"Stopped FileOffsetBackingStore","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.746Z","sequence":180,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.ConnectorLifecycle","level":"ERROR","message":"Connector completed: success = 'false', message = 'Error while trying to stop the task and commit the offsets', error = 'io.debezium.connector.cassandra.exceptions.CassandraConnectorTaskException: java.lang.NullPointerException'","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1,"exception":{"refId":1,"exceptionType":"io.debezium.connector.cassandra.exceptions.CassandraConnectorTaskException","message":"java.lang.NullPointerException","frames":[{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"doStop","line":94},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":293},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":267},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":946},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}],"causedBy":{"exception":{"refId":2,"exceptionType":"java.lang.NullPointerException","message":null,"frames":[{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"doStop","line":91},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":293},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":267},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":946},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}]}}}}
Do you see the same behaviour using the latest relesead Debezium version?
We use the latest version of Debezium/server docker container.
Do you have the connector logs, ideally from start till finish?
(You might be asked later to provide DEBUG/TRACE level log)
Defaulted container "cassandra-cdc" out of: cassandra-cdc, volume-init (init) NOTE: Picked up JDK_JAVA_OPTIONS: --add-exports java.base/jdk.internal.misc=ALL-UNNAMED --add-exports java.base/jdk.internal.ref=ALL-UNNAMED --add-exports java.base/sun.nio.ch=ALL-UNNAMED --add-exports java.management.rmi/com.sun.jmx.remote.internal.rmi=ALL-UNNAMED --add-exports java.rmi/sun.rmi.registry=ALL-UNNAMED --add-exports java.rmi/sun.rmi.server=ALL-UNNAMED --add-exports java.sql/java.sql=ALL-UNNAMED --add-opens java.base/java.lang.module=ALL-UNNAMED --add-opens java.base/jdk.internal.loader=ALL-UNNAMED --add-opens java.base/jdk.internal.ref=ALL-UNNAMED --add-opens java.base/jdk.internal.reflect=ALL-UNNAMED --add-opens java.base/jdk.internal.math=ALL-UNNAMED --add-opens java.base/jdk.internal.module=ALL-UNNAMED --add-opens java.base/jdk.internal.util.jar=ALL-UNNAMED --add-opens jdk.management/com.sun.management.internal=ALL-UNNAMED --add-opens=java.base/java.io=ALL-UNNAMED --add-opens java.base/sun.nio.ch=ALL-UNNAMED SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/debezium/lib/slf4j-jboss-logmanager-1.2.0.Final.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/debezium/lib/logback-classic-1.2.10.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Slf4jLoggerFactory] {"timestamp":"2023-06-26T06:38:24.013Z","sequence":133,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.BaseChangeConsumer","level":"INFO","message":"Using 'io.debezium.server.BaseChangeConsumer$$Lambda$202/0x0000000840289840@6fd5717c' stream name mapper","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.apache.pulsar.common.util.netty.DnsResolverUtil (file:/debezium/lib/pulsar-client-2.10.1.jar) to method sun.net.InetAddressCachePolicy.get() WARNING: Please consider reporting this to the maintainers of org.apache.pulsar.common.util.netty.DnsResolverUtil WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release {"timestamp":"2023-06-26T06:38:24.515Z","sequence":134,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.DebeziumServer","level":"INFO","message":"Consumer 'io.debezium.server.pulsar.PulsarChangeConsumer' instantiated","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.613Z","sequence":135,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.json.JsonConverterConfig","level":"INFO","message":"JsonConverterConfig values: \n\tconverter.type = key\n\tdecimal.format = BASE64\n\tschemas.cache.size = 1000\n\tschemas.enable = false\n","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.616Z","sequence":136,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.json.JsonConverterConfig","level":"INFO","message":"JsonConverterConfig values: \n\tconverter.type = value\n\tdecimal.format = BASE64\n\tschemas.cache.size = 1000\n\tschemas.enable = false\n","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.628Z","sequence":137,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.embedded.EmbeddedEngine$EmbeddedConfig","level":"INFO","message":"EmbeddedConfig values: \n\taccess.control.allow.methods = \n\taccess.control.allow.origin = \n\tadmin.listeners = null\n\tauto.include.jmx.reporter = true\n\tbootstrap.servers = [localhost:9092]\n\tclient.dns.lookup = use_all_dns_ips\n\tconfig.providers = []\n\tconnector.client.config.override.policy = All\n\theader.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter\n\tkey.converter = class org.apache.kafka.connect.json.JsonConverter\n\tlisteners = [http://:8083]\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\toffset.flush.interval.ms = 60000\n\toffset.flush.timeout.ms = 5000\n\toffset.storage.file.filename = data/offsets.dat\n\toffset.storage.partitions = null\n\toffset.storage.replication.factor = null\n\toffset.storage.topic = \n\tplugin.path = null\n\tresponse.http.headers.config = \n\trest.advertised.host.name = null\n\trest.advertised.listener = null\n\trest.advertised.port = null\n\trest.extension.classes = []\n\tssl.cipher.suites = null\n\tssl.client.auth = none\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n\ttask.shutdown.graceful.timeout.ms = 5000\n\ttopic.creation.enable = true\n\ttopic.tracking.allow.reset = true\n\ttopic.tracking.enable = true\n\tvalue.converter = class org.apache.kafka.connect.json.JsonConverter\n","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.629Z","sequence":138,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.runtime.WorkerConfig","level":"WARN","message":"Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results.","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.635Z","sequence":139,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.json.JsonConverterConfig","level":"INFO","message":"JsonConverterConfig values: \n\tconverter.type = key\n\tdecimal.format = BASE64\n\tschemas.cache.size = 1000\n\tschemas.enable = true\n","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.635Z","sequence":140,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.json.JsonConverterConfig","level":"INFO","message":"JsonConverterConfig values: \n\tconverter.type = value\n\tdecimal.format = BASE64\n\tschemas.cache.size = 1000\n\tschemas.enable = true\n","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.636Z","sequence":141,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.json.JsonConverterConfig","level":"INFO","message":"JsonConverterConfig values: \n\tconverter.type = header\n\tdecimal.format = BASE64\n\tschemas.cache.size = 1000\n\tschemas.enable = true\n","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.638Z","sequence":142,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.DebeziumServer","level":"INFO","message":"Engine executor started","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.651Z","sequence":143,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.storage.FileOffsetBackingStore","level":"INFO","message":"Starting FileOffsetBackingStore with file data/offsets.dat","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.665Z","sequence":144,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":"Starting Cassandra4ConnectorTask with configuration:","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.669Z","sequence":145,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" connector.class = io.debezium.connector.cassandra.Cassandra4Connector","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.669Z","sequence":146,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" slot.name = development_paypaplane_cassandra","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.669Z","sequence":147,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" cassandra.ssl.enabled = false","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.669Z","sequence":148,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" cassandra.hosts = workspace","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.67Z","sequence":149,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" cassandra.port = 9042","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.67Z","sequence":150,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" schema.history.internal.pulsar.tenant = development_paypaplane","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.67Z","sequence":151,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" json-with-envelope = false","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.67Z","sequence":152,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" topic.prefix = cassandra","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.67Z","sequence":153,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.storage.file.filename = data/offsets.dat","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.671Z","sequence":154,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.storage.pulsar.client.serviceUrl = pulsar://proxy.pulsar.dev.paypaplane.net","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.671Z","sequence":155,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" errors.retry.delay.initial.ms = 300","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.671Z","sequence":156,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.storage.pulsar.tenant = development_paypaplane","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.672Z","sequence":157,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" commit.log.relocation.dir = cassandra/relocdir","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.672Z","sequence":158,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" schema.history.internal.pulsar.client.serviceUrl = pulsar://proxy.pulsar.dev.paypaplane.net","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.672Z","sequence":159,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" value.converter = org.apache.kafka.connect.json.JsonConverter","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.672Z","sequence":160,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" key.converter = org.apache.kafka.connect.json.JsonConverter","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.673Z","sequence":161,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" cassandra.config = /debezium/data/cassandra.yaml","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.673Z","sequence":162,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" http.port = 8040","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":163,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" schema.history.internal.pulsar.namespace = development_paypaplane_cassandra","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":164,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":165,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.flush.timeout.ms = 5000","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":166,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" errors.retry.delay.max.ms = 10000","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":167,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" collection = public.dbz_signal","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":168,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.storage.pulsar.namespace = development_paypaplane_cassandra","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.674Z","sequence":169,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" schema.whitelist = public","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.675Z","sequence":170,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" offset.flush.interval.ms = 60000","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.675Z","sequence":171,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" errors.max.retries = -1","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.675Z","sequence":172,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" name = pulsar","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.675Z","sequence":173,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":" cassandra.node.id = sample_node_01","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.677Z","sequence":174,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":"Attempting to start task","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.737Z","sequence":175,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":"No previous offsets found","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.743Z","sequence":176,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.embedded.EmbeddedEngine","level":"INFO","message":"Stopping the task and engine","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.743Z","sequence":177,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.connector.common.BaseSourceTask","level":"INFO","message":"Stopping down connector","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.744Z","sequence":178,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.embedded.EmbeddedEngine","level":"ERROR","message":"Error while trying to run connector class 'io.debezium.connector.cassandra.Cassandra4Connector'","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1,"exception":{"refId":1,"exceptionType":"java.lang.NoClassDefFoundError","message":"org/eclipse/jetty/server/Handler","frames":[{"class<span class="code-quote">":"io.debezium.connector.cassandra.CassandraConnectorTask","method":"init","line":47},{"class<span class="code-quote">":"io.debezium.connector.cassandra.Cassandra4ConnectorTask","method":"init","line":12},{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"start","line":69},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"startIfNeededAndPossible","line":244},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"poll","line":153},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":853},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}],"causedBy":{"exception":{"refId":2,"exceptionType":"java.lang.ClassNotFoundException","message":"org.eclipse.jetty.server.Handler","frames":[{"class<span class="code-quote">":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","line":581},{"class<span class="code-quote">":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","line":178},{"class<span class="code-quote">":"java.lang.ClassLoader","method":"loadClass","line":522},{"class<span class="code-quote">":"io.debezium.connector.cassandra.CassandraConnectorTask","method":"init","line":47},{"class<span class="code-quote">":"io.debezium.connector.cassandra.Cassandra4ConnectorTask","method":"init","line":12},{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"start","line":69},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"startIfNeededAndPossible","line":244},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"poll","line":153},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":853},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}]}}}} {"timestamp":"2023-06-26T06:38:24.745Z","sequence":179,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.kafka.connect.storage.FileOffsetBackingStore","level":"INFO","message":"Stopped FileOffsetBackingStore","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.746Z","sequence":180,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.ConnectorLifecycle","level":"ERROR","message":"Connector completed: success = 'false', message = 'Error while trying to stop the task and commit the offsets', error = 'io.debezium.connector.cassandra.exceptions.CassandraConnectorTaskException: java.lang.NullPointerException'","threadName":"pool-7-thread-1","threadId":21,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1,"exception":{"refId":1,"exceptionType":"io.debezium.connector.cassandra.exceptions.CassandraConnectorTaskException","message":"java.lang.NullPointerException","frames":[{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"doStop","line":94},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":293},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":267},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":946},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}],"causedBy":{"exception":{"refId":2,"exceptionType":"java.lang.NullPointerException","message":null,"frames":[{"class<span class="code-quote">":"io.debezium.connector.cassandra.AbstractConnectorTask","method":"doStop","line":91},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":293},{"class<span class="code-quote">":"io.debezium.connector.common.BaseSourceTask","method":"stop","line":267},{"class<span class="code-quote">":"io.debezium.embedded.EmbeddedEngine","method":"run","line":946},{"class<span class="code-quote">":"io.debezium.embedded.ConvertingEngineBuilder$2","method":"run","line":229},{"class<span class="code-quote">":"io.debezium.server.DebeziumServer","method":"lambda$start$1","line":170},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor","method":"runWorker","line":1128},{"class<span class="code-quote">":"java.util.concurrent.ThreadPoolExecutor$Worker","method":"run","line":628},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":829}]}}}} {"timestamp":"2023-06-26T06:38:24.792Z","sequence":181,"loggerClassName":"org.jboss.logging.Logger","loggerName":"io.quarkus","level":"INFO","message":"debezium-server-dist 2.2.0.Alpha3 on JVM (powered by Quarkus 2.16.3.Final) started in 2.405s. Listening on: http://0.0.0.0:8080","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.793Z","sequence":182,"loggerClassName":"org.jboss.logging.Logger","loggerName":"io.quarkus","level":"INFO","message":"Profile prod activated. ","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.793Z","sequence":183,"loggerClassName":"org.jboss.logging.Logger","loggerName":"io.quarkus","level":"INFO","message":"Installed features: [cdi, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health, vertx]","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.81Z","sequence":184,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.DebeziumServer","level":"INFO","message":"Received request to stop the engine","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.81Z","sequence":185,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.embedded.EmbeddedEngine","level":"INFO","message":"Stopping the embedded engine","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:24.811Z","sequence":186,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.apache.pulsar.client.impl.PulsarClientImpl","level":"INFO","message":"Client closing. URL: pulsar://proxy.pulsar.dev.paypaplane.net","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1} {"timestamp":"2023-06-26T06:38:26.856Z","sequence":187,"loggerClassName":"org.jboss.logging.Logger","loggerName":"io.quarkus","level":"INFO","message":"debezium-server-dist stopped in 2.058s","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"cassandra-cdc-0","processName":"io.debezium.server.Main","processId":1}
How to reproduce the issue using our tutorial deployment?
We used the following liknks:
debezium/documentation/modules/ROOT/pages/operations/debezium-server.adoc at 0baad2f7b7177dc8152e66c1194986da9f06a2fe · debezium/debezium (github.com)
