运行debezium cassandra连接器时出现cassandra错误

jtjikinw  于 2021-06-13  发布在  Cassandra
关注(0)|答案(0)|浏览(338)

我在运行debezium cassandra connector:for cdc时遇到以下错误

  1. sudo java -jar /home/centos/debezium-connector-cassandra-1.2.0.Beta2-jar-with-dependencies.jar /home/centos/debezium-connector-cassandra/deb_conf.properties

错误:

  1. Exception in thread "main" org.apache.cassandra.exceptions.ConfigurationException: Error instantiating snitch class 'org.apache.cassandra.locator.GossipingPropertyFileSnitch'.
  2. at org.apache.cassandra.utils.FBUtilities.construct(FBUtilities.java:596)
  3. at org.apache.cassandra.utils.FBUtilities.construct(FBUtilities.java:574)
  4. at org.apache.cassandra.config.DatabaseDescriptor.createEndpointSnitch(DatabaseDescriptor.java:1045)
  5. at org.apache.cassandra.config.DatabaseDescriptor.applySnitch(DatabaseDescriptor.java:969)
  6. at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:192)
  7. at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:157)
  8. at io.debezium.connector.cassandra.CassandraConnectorContext.loadDdlFromDisk(CassandraConnectorContext.java:64)
  9. at io.debezium.connector.cassandra.CassandraConnectorContext.<init>(CassandraConnectorContext.java:36)
  10. at io.debezium.connector.cassandra.CassandraConnectorTask.run(CassandraConnectorTask.java:72)
  11. at io.debezium.connector.cassandra.CassandraConnectorTask.main(CassandraConnectorTask.java:61)
  12. Caused by: org.apache.cassandra.exceptions.ConfigurationException: DC or rack not found in snitch properties, check your configuration in: cassandra-rackdc.properties
  13. at org.apache.cassandra.locator.GossipingPropertyFileSnitch.loadConfiguration(GossipingPropertyFileSnitch.java:76)
  14. at org.apache.cassandra.locator.GossipingPropertyFileSnitch.<init>(GossipingPropertyFileSnitch.java:54)
  15. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  16. at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
  17. at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  18. at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
  19. at java.lang.Class.newInstance(Class.java:442)
  20. at org.apache.cassandra.utils.FBUtilities.construct(FBUtilities.java:581)
  21. ... 9 more

我查过了 cassandra-rackdc.properties 存在于
/etc/cassandra/ Cassandra Version: Cassandra 3.11.6 我把这些参数改了 cassandra.yaml ```
cdc_enabled: true
cdc_raw_directory: /var/lib/cassandra/cdc_raw
cdc_total_space_in_mb: 4096
cdc_free_space_check_interval_ms: 250

  1. 编辑:Cassandra家定义和正确。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题