debezium cassandra connector not working

[Dummy Account]

Hi am trying to run the debezium jar with the following command and its giving me an output with an error saying invalid yaml file. Please suggest me a proper solution to work around this issue. Thanks.

java -jar debezium-connector-cassandra-1.1.1.Final-jar-with-dependencies.jar

/opt/idam/cdc_connect.properties
17:45:59.262 [main] INFO  i.d.c.c.CassandraConnectorTask - Initializing Cassandra connector task context ...
17:45:59.368 [main] INFO  o.a.c.config.YamlConfigurationLoader - Configuration location: file:////opt/idam/apache-cassandra-4.1.2/conf/cassandra.yaml
17:45:59.369 [main] DEBUG o.a.c.config.YamlConfigurationLoader - Loading settings from file:////opt/idam/apache-cassandra-4.1.2/conf/cassandra.yaml
Exception in thread "main" org.apache.cassandra.exceptions.ConfigurationException: Invalid yaml: file:////opt/idam/apache-cassandra-4.1.2/conf/cassandra.yaml
 Error: null; Can't construct a java object for tag:yaml.org,2002:org.apache.cassandra.config.Config; exception=Cannot create property=key_cache_save_period for JavaBean=org.apache.cassandra.config.Config@7ce6a65d; For input string: "4h";  in 'reader', line 11, column 1:
    cluster_name: 'Test'
    ^
at org.apache.cassandra.config.YamlConfigurationLoader.loadConfig(YamlConfigurationLoader.java:131)
at org.apache.cassandra.config.YamlConfigurationLoader.loadConfig(YamlConfigurationLoader.java:101)
at org.apache.cassandra.config.DatabaseDescriptor.loadConfig(DatabaseDescriptor.java:268)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:186)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:157)
at io.debezium.connector.cassandra.CassandraConnectorContext.loadDdlFromDisk(CassandraConnectorContext.java:64)
at io.debezium.connector.cassandra.CassandraConnectorContext.<init>(CassandraConnectorContext.java:36)
at io.debezium.connector.cassandra.CassandraConnectorTask.run(CassandraConnectorTask.java:72)
at io.debezium.connector.cassandra.CassandraConnectorTask.main(CassandraConnectorTask.java:61)

[jiri.p...@gmail.com]

Hi,

are you sure the cassandra.yaml you use does not contain any options not available for Cassandra 4?

J.

[Dummy Account]

Hi when i try to run debezium cassandra plugin jar having version 4, with the cdc_connect.properties of cassandra which is also running on version 4, it gives me an following error.
I checked the java and javac version on the machine and both are same.
Please help me to find the work around for the issue that am facing


java -jar debezium-connector-cassandra-4-2.4.0.Final-jar-with-dependencies.jar /opt/idam/cdc_connect.properties

 
Error: A JNI error has occurred, please check your installation and try again
Exception in thread "main" java.lang.UnsupportedClassVersionError: io/debezium/connector/cassandra/CassandraConnectorTask has been compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:756)
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:468)
at java.net.URLClassLoader.access$100(URLClassLoader.java:74)
at java.net.URLClassLoader$1.run(URLClassLoader.java:369)
at java.net.URLClassLoader$1.run(URLClassLoader.java:363)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:362)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:355)
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:495)

Thanks,

Yash

[jiri.p...@gmail.com]

Hi,

please make sure you use Java 11.

Jiri

[Dummy Account]

Hi, these are the details of the java version that am currently using

java -version

java version "1.8.0_241"
Java(TM) SE Runtime Environment (build 1.8.0_241-b07)
Java HotSpot(TM) 64-Bit Server VM (build 25.241-b07, mixed mode)

javac -version

javac 1.8.0_241

I will consider using java 11, but i would like to know the reason that why this java version is not supported!

Thanks.

[jiri.p...@gmail.com]

Hi,

Debezium has moved to Java 11 starting Debezium as manadatory minimum

Jiri

[Ahmed Eljami]

Hi,

You are using Cassandra-4.1, this version introduces the standarize of Cassandra config https://issues.apache.org/jira/browse/CASSANDRA-15234

In your case, The YamlConfigurationLoader is trying to read and construct a property that had the following value before Cassandra-4.1:

key_cache_save_period: 14400

Since Cassandra-4.1, we have the following value:

key_cache_save_period: 4h

I think that we should work on new PR to fix this and make sure tu support Cassandra 4.1+

--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/6dd4e37a-6c6f-4fea-be4f-a20faab033adn%40googlegroups.com.

--

Cordialement;

Ahmed ELJAMI

[Dummy Account]

Yes Ahmed, it will be a great help

Thanks.

[Dummy Account]

Hi Jiri, 

I have used java 11 to run the debezium cassadra connector on cassandra version 4.0.11 and am getting the following error output, any help or work around this issue would be appreciated.

commad used:  /java -jar /opt/idam/debezium-connector-cassandra-4-2.0.0.Final-jar-with-dependencies.jar /opt/idam/cdc_connect.properties

15:08:16.010 [main] ERROR org.apache.cassandra.io.util.FileUtils - FATAL: Cassandra is unable to access required classes. This usually means it has been run without the aid of the standard startup scripts or the scripts have been edited. If this was intentional, and you are attempting to use Java 11+ you may need to add the --add-exports and --add-opens jvm options from either jvm11-server.options or jvm11-client.options
java.lang.IllegalAccessException: access to public member failed: jdk.internal.ref.Cleaner.clean[Ljava.lang.Object;@5f031ebd/invokeVirtual, from org.apache.cassandra.io.util.FileUtils (unnamed module @5906ebcb)
at java.base/java.lang.invoke.MemberName.makeAccessException(MemberName.java:942)
at java.base/java.lang.invoke.MethodHandles$Lookup.checkAccess(MethodHandles.java:2201)
at java.base/java.lang.invoke.MethodHandles$Lookup.checkMethod(MethodHandles.java:2141)
at java.base/java.lang.invoke.MethodHandles$Lookup.getDirectMethodCommon(MethodHandles.java:2285)
at java.base/java.lang.invoke.MethodHandles$Lookup.getDirectMethodNoSecurityManager(MethodHandles.java:2278)
at java.base/java.lang.invoke.MethodHandles$Lookup.unreflect(MethodHandles.java:1747)
at org.apache.cassandra.io.util.FileUtils.<clinit>(FileUtils.java:96)
at org.apache.cassandra.config.DatabaseDescriptor.guessFileStore(DatabaseDescriptor.java:1193)
at org.apache.cassandra.config.DatabaseDescriptor.applySimpleConfig(DatabaseDescriptor.java:550)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:218)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:187)
at io.debezium.connector.cassandra.CassandraConnectorTask$Cassandra4SchemaLoader.load(CassandraConnectorTask.java:26)
at io.debezium.connector.cassandra.CassandraConnectorContext.<init>(CassandraConnectorContext.java:51)
at io.debezium.connector.cassandra.CassandraConnectorTaskTemplate.run(CassandraConnectorTaskTemplate.java:104)
at io.debezium.connector.cassandra.CassandraConnectorTaskTemplate.main(CassandraConnectorTaskTemplate.java:64)
at io.debezium.connector.cassandra.CassandraConnectorTask.main(CassandraConnectorTask.java:43)
15:08:16.013 [main] INFO io.debezium.connector.cassandra.CassandraConnectorTaskTemplate - Stopping Cassandra Connector Task ...
15:08:16.013 [main] INFO io.debezium.connector.cassandra.CassandraConnectorTaskTemplate - Stopped Cassandra Connector Task.
Exception in thread "main" java.lang.ExceptionInInitializerError
at org.apache.cassandra.config.DatabaseDescriptor.guessFileStore(DatabaseDescriptor.java:1193)
at org.apache.cassandra.config.DatabaseDescriptor.applySimpleConfig(DatabaseDescriptor.java:550)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:218)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:187)
at io.debezium.connector.cassandra.CassandraConnectorTask$Cassandra4SchemaLoader.load(CassandraConnectorTask.java:26)
at io.debezium.connector.cassandra.CassandraConnectorContext.<init>(CassandraConnectorContext.java:51)
at io.debezium.connector.cassandra.CassandraConnectorTaskTemplate.run(CassandraConnectorTaskTemplate.java:104)
at io.debezium.connector.cassandra.CassandraConnectorTaskTemplate.main(CassandraConnectorTaskTemplate.java:64)
at io.debezium.connector.cassandra.CassandraConnectorTask.main(CassandraConnectorTask.java:43)
Caused by: java.lang.RuntimeException: java.lang.IllegalAccessException: access to public member failed: jdk.internal.ref.Cleaner.clean[Ljava.lang.Object;@5f031ebd/invokeVirtual, from org.apache.cassandra.io.util.FileUtils (unnamed module @5906ebcb)
at org.apache.cassandra.io.util.FileUtils.<clinit>(FileUtils.java:107)
... 9 more
Caused by: java.lang.IllegalAccessException: access to public member failed: jdk.internal.ref.Cleaner.clean[Ljava.lang.Object;@5f031ebd/invokeVirtual, from org.apache.cassandra.io.util.FileUtils (unnamed module @5906ebcb)
at java.base/java.lang.invoke.MemberName.makeAccessException(MemberName.java:942)
at java.base/java.lang.invoke.MethodHandles$Lookup.checkAccess(MethodHandles.java:2201)
at java.base/java.lang.invoke.MethodHandles$Lookup.checkMethod(MethodHandles.java:2141)
at java.base/java.lang.invoke.MethodHandles$Lookup.getDirectMethodCommon(MethodHandles.java:2285)
at java.base/java.lang.invoke.MethodHandles$Lookup.getDirectMethodNoSecurityManager(MethodHandles.java:2278)
at java.base/java.lang.invoke.MethodHandles$Lookup.unreflect(MethodHandles.java:1747)
at org.apache.cassandra.io.util.FileUtils.<clinit>(FileUtils.java:96)
... 9 more

[Ahmed Eljami]

You have to add the following --add-export :

/java 

-Djdk.attach.allowAttachSelf=true --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

/opt/idam/debezium-connector-cassandra-4-2.0.0.Final-jar-with-dependencies.jar /opt/idam/cdc_connect.properties

--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.

To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/98c5cca9-b540-48fe-a24f-7f113872f56an%40googlegroups.com.

--

Cordialement;

Ahmed ELJAMI

[Dummy Account]

Hi all,

I was able to successfully integrate the cassandra connector plugin and the cdc logs are also getting pushed into the kafka queue.

Thanks for all your help!!

--
You received this message because you are subscribed to a topic in the Google Groups "debezium" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/debezium/LetbQhkDKz8/unsubscribe.
To unsubscribe from this group and all its topics, send an email to debezium+u...@googlegroups.com.

[Ishant Bhatia]

Can you show me the msg you are pushing to kafka, 


I am getting 

20:34:46.251 [main] INFO io.debezium.connector.cassandra.CassandraConnectorTaskTemplate - Starting JMX reporter ...

20:34:46.260 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Node -1 has finalized features epoch: 0, finalized features: [], supported features: [], API versions: (Produce(0): 0 to 10 [usable: 9], Fetch(1): 0 to 16 [usable: 13], ListOffsets(2): 0 to 8 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 7 [usable: 6], StopReplica(5): 0 to 4 [usable: 3], UpdateMetadata(6): 0 to 8 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 9 [usable: 8], OffsetFetch(9): 0 to 9 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 4 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 3 [usable: 2], CreateAcls(30): 0 to 3 [usable: 2], DeleteAcls(31): 0 to 3 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 4 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 3 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 3 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 3 [usable: 1], UpdateFeatures(57): 0 to 1 [usable: 0], Envelope(58): 0 [usable: 0], DescribeCluster(60): 0 to 1 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], UNKNOWN(68): 0).

20:34:46.265 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node localhost:9092 (id: -1 rack: null)

20:34:46.265 [main] INFO io.debezium.connector.cassandra.CassandraConnectorTaskTemplate - Stopping Cassandra Connector Task ...

20:34:46.265 [main] INFO io.debezium.connector.cassandra.CassandraConnectorTaskTemplate$ProcessorGroup - Terminating processor group ...

20:34:46.265 [main] INFO org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

20:34:46.266 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=producer-1, correlationId=1) and timeout 30000 to node -1: MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false)

20:34:46.267 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node localhost:9092 (id: -1 rack: null) with correlation ID 2

20:34:46.267 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending INIT_PRODUCER_ID request with header RequestHeader(apiKey=INIT_PRODUCER_ID, apiVersion=4, clientId=producer-1, correlationId=2) and timeout 30000 to node -1: InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)

20:34:46.267 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records.

0:34:46.267 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records.

20:34:46.274 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received METADATA response from node -1 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=producer-1, correlationId=1): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='localhost', port=9092, rack=null)], clusterId='A_LM79J0QSm6F1frhTu9yg', controllerId=0, topics=[], clusterAuthorizedOperations=-2147483648)

20:34:46.278 [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Cluster ID: A_LM79J0QSm6F1frhTu9yg

20:34:46.278 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='A_LM79J0QSm6F1frhTu9yg', nodes={0=localhost:9092 (id: 0 rack: null)}, partitions=[], controller=localhost:9092 (id: 0 rack: null)}

20:34:46.303 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Received INIT_PRODUCER_ID response from node -1 for request with header RequestHeader(apiKey=INIT_PRODUCER_ID, apiVersion=4, clientId=producer-1, correlationId=2): InitProducerIdResponseData(throttleTimeMs=0, errorCode=14, producerId=-1, producerEpoch=-1)

20:34:46.304 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.TransactionManager - [Producer clientId=producer-1] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)

20:34:46.310 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Shutdown of Kafka producer I/O thread has completed.

20:34:46.314 [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed

20:34:46.314 [pool-4-thread-4] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed

20:34:46.314 [main] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

20:34:46.314 [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed

20:34:46.314 [pool-4-thread-4] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

20:34:46.314 [pool-4-thread-4] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed

20:34:46.316 [main] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.producer for producer-1 unregistered

20:34:46.316 [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Kafka producer has been closed

20:34:46.316 [main] INFO io.debezium.connector.cassandra.AbstractProcessor - Stopping Snapshot Processor

20:34:46.317 [pool-4-thread-4] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.producer for producer-1 unregistered

20:34:46.317 [pool-4-thread-4] DEBUG org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Kafka producer has been closed

20:34:46.317 [pool-4-thread-4] INFO io.debezium.connector.cassandra.AbstractProcessor - Stopping Commit Log Processor

20:34:46.317 [main] INFO io.debezium.connector.cassandra.AbstractProcessor - Stopping Commit Log Processor

20:34:46.833 [pool-4-thread-2] DEBUG io.debezium.connector.base.ChangeEventQueue - checking for more records...

20:34:46.836 [pool-4-thread-2] DEBUG io.debezium.connector.cassandra.KafkaRecordEmitter - Sending the record 'Record{source={cluster=cassandra_cdc, keyspace=ncl, file=, connector=cassandra, pos=-1, ts_micro=1750086286009000, version=${project.version}, snapshot=true, table=cdc_events}, after={event_id={name=event_id, value=ishant9, deletionTs=null, type=PARTITION}, event_source={name=event_source, value=ishant9, deletionTs=null, type=REGULAR}}, keySchema=Schema{io.debezium.connector.cassandra.cassandra_cdc.ncl.cdc_events.Key:STRUCT}, valueSchema=Schema{io.debezium.connector.cassandra.cassandra_cdc.ncl.cdc_events.Envelope:STRUCT}, op=i, ts=1750086286108}'

20:34:46.856 [pool-4-thread-2] ERROR io.debezium.connector.cassandra.QueueProcessor - Processing of event Record{source={cluster=cassandra_cdc, keyspace=ncl, file=, connector=cassandra, pos=-1, ts_micro=1750086286009000, version=${project.version}, snapshot=true, table=cdc_events}, after={event_id={name=event_id, value=ishant9, deletionTs=null, type=PARTITION}, event_source={name=event_source, value=ishant9, deletionTs=null, type=REGULAR}}, keySchema=Schema{io.debezium.connector.cassandra.cassandra_cdc.ncl.cdc_events.Key:STRUCT}, valueSchema=Schema{io.debezium.connector.cassandra.cassandra_cdc.ncl.cdc_events.Envelope:STRUCT}, op=i, ts=1750086286108} was errorneous: {}

io.debezium.DebeziumException: Failed to send record Record{source={cluster=cassandra_cdc, keyspace=ncl, file=, connector=cassandra, pos=-1, ts_micro=1750086286009000, version=${project.version}, snapshot=true, table=cdc_events}, after={event_id={name=event_id, value=ishant9, deletionTs=null, type=PARTITION}, event_source={name=event_source, value=ishant9, deletionTs=null, type=REGULAR}}, keySchema=Schema{io.debezium.connector.cassandra.cassandra_cdc.ncl.cdc_events.Key:STRUCT}, valueSchema=Schema{io.debezium.connector.cassandra.cassandra_cdc.ncl.cdc_events.Envelope:STRUCT}, op=i, ts=1750086286108}

at io.debezium.connector.cassandra.KafkaRecordEmitter.emit(KafkaRecordEmitter.java:72)

at io.debezium.connector.cassandra.QueueProcessor.processEvent(QueueProcessor.java:114)

at io.debezium.connector.cassandra.QueueProcessor.process(QueueProcessor.java:72)

at io.debezium.connector.cassandra.AbstractProcessor.start(AbstractProcessor.java:63)

Caused by: java.lang.IllegalStateException: Cannot perform operation after producer has been closed

a

[jiri.p...@gmail.com]

I wonder why "Stopping Cassandra Connector Task" is tiggered as the following errors are just  caused by terminating Cassandra connector in the first place

Jiri