Весенние данные с Кассандрой, дающей IllegalStateException - PullRequest
Новая
       50

Весенние данные с Кассандрой, дающей IllegalStateException

0 голосов
/ 13 марта 2020

Я совершенно новичок в Кассандре, поэтому моя ошибка может быть очевидной.

Я пытаюсь создать приложение с весенней загрузкой (версия 2.3.0.M2), которое связывается с cassandra (версия 3.11.6), установленным в localhost.

У меня есть java .lang.IllegalStateException с сообщением: поскольку вы указали явные точки контакта, локальный D C должен быть явно установлен (см. Basi c .load-balancing- policy.local-datacenter в конфиге или установить его программно с помощью SessionBuilder.withLocalDatacenter). Текущие контактные точки: Узел (конечная точка = localhost: 9042, hostId = 16a785a4-eaf3-4a4d-a216-5244d75206aa, hashCode = 7b0b99d7) = datacenter1. Текущие контроллеры домена в этом кластере: datacenter1

Мой pom следующий: 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.M2</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.test</groupId>
    <artifactId>cassandra</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>cassandra</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-cassandra</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
    </repositories>
    <pluginRepositories>
        <pluginRepository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </pluginRepository>
    </pluginRepositories>
</project>

В коде приложения у меня есть следующий класс конфигурации: 

public class CassandraConfig extends AbstractCassandraConfiguration {

    public static final String KEYSPACE = "test_keyspace";


    @Override
    public SchemaAction getSchemaAction() {
        return SchemaAction.CREATE_IF_NOT_EXISTS;
    }

    @Override
    protected List<CreateKeyspaceSpecification> getKeyspaceCreations() {
        CreateKeyspaceSpecification specification = CreateKeyspaceSpecification.createKeyspace(KEYSPACE);

        return Arrays.asList(specification);
    }

    @Override
    protected List<DropKeyspaceSpecification> getKeyspaceDrops() {
        return Arrays.asList(DropKeyspaceSpecification.dropKeyspace(KEYSPACE));
    }

    @Override
    protected String getKeyspaceName() {
        return KEYSPACE;
    }

    @Override
    public String[] getEntityBasePackages() {
        return new String[]{"com.test.cassandra.entity"};
    }
}

Мой файл свойств содержит следующую конфигурацию: 

spring.data.cassandara.keyspace-name=test_keyspace
spring.data.cassandra.contact-points=localhost
spring.data.cassanda.port=9042
spring.data.cassandra.schema-act=create_if_not_exists

Я также пытался использовать 

spring.data.cassandra.contact-points=dc1

Когда я запускаю приложение, я вижу из журналов, что я ' используя следующую версию DataStax Java драйвер для Apache Cassandra (R) (com.datastax.oss: java -driver-core) версия 4.4.0

В cassandra-rackd c .properties Я установил имя 

dc=dc1

Я провел несколько тестов, добавив параметры конфигурации, даже добавив application.conf в classpath, как описано в документации по datastax, но безуспешно , Любая подсказка, где я должен это сделать?

1 Ответ

0 голосов
/ 07 апреля 2020

Начиная с Spring Boot 2.3.0.X вам необходимо явно указать имя локального центра данных (из-за добавленной поддержки драйвера Cassandra 4.X, которая требует явной установки локального центра данных). Вы можете сделать это, переопределив метод getLocalDataCenter в AbstractSessionConfiguration. AbstractCassandraConfiguration расширяет этот класс, так что вам просто нужно добавить в свой CassandraConfig класс: 

@Override
protected String getLocalDataCenter() {
    return "dc1";
}
...