Невозможно написать пользовательские запросы, используя Spring WebFlux и ReactiveCassandraRepository - PullRequest
0 голосов
/ 25 октября 2018

Я пытаюсь подключить Spring WebFlux (весеннюю загрузку версии 2.0.6) к Dasastax Cassandra DSE3.x.Но когда я пытаюсь запросить таблицу Cassandra с помощью ReactiveCassandraRepository с пользовательским запросом, я получаю следующую ошибку.Однако я могу получить количество записей из этой таблицы.

Неподдерживаемая функция с собственным протоколом V1 (который в настоящее время используется): двоичные значения не поддерживаются;вложенным исключением является com.datastax.driver.core.exceptions.UnsupportedFeatureException: неподдерживаемая функция с собственным протоколом V1 (который в настоящее время используется): двоичные значения не поддерживаются "

Мой код репозитория равен

public interface SystemLookupReactiveRepository extends ReactiveCrudRepository<SystemLookup, String> {

@AllowFiltering
@Query("{SELECT * FROM \"SystemLookup\" WHERE LookupId = ?0 ALLOW FILTERING}")
Mono<SystemLookup> findByLookupId(String lookupId);}

Мой файл POM:

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-cassandra-reactive</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
        <exclusions>
            <exclusion>
                <artifactId>spring-boot-starter-reactor-netty</artifactId>
                <groupId>org.springframework.boot</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-tomcat</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>io.projectreactor</groupId>
        <artifactId>reactor-test</artifactId>
        <scope>test</scope>
    </dependency>
...