Шаблон Cassandra обновляет определенный целочисленный столбец таблицы Cassandra, но в БД он не отражает обновленное значение - PullRequest
Новая
       12

Шаблон Cassandra обновляет определенный целочисленный столбец таблицы Cassandra, но в БД он не отражает обновленное значение

0 голосов
/ 22 января 2020

В моем весеннем потребителе Kafka мы пытаемся обновить целочисленный столбец таблицы Cassandra, и из журналов приложений я вижу, что все прошло нормально, но когда я проверяю таблицу Cassandra, значения не обновляются. Ниже приведен шаблон Cassandra, который я использую для обновления столбца записи. 

public boolean updaetCassandraTable(String primaryKey1, String primaryKey2, String primaryKey3,
            String column_to_update1, String column_to_update2){

        Update update = QueryBuilder.update("Table_to_update");
        update.where(eq("primaryKey1", primaryKey1))
                .and(eq("primaryKey2", primaryKey2))
                .and(eq("primaryKey3", primaryKey3))                
                .with(set("column_to_update1", column_to_update1))
                .and(set("column_to_update2", column_to_update2));              

        return cassandraTemplate.getCqlOperations().execute(update);
    }

Кроме того, если я отключаю потребителя и позволяю сообщениям накапливаться в topi c, а после этого, если я перезапускаю потребителя, то все собранные сообщения обрабатываются нормально. Проблема возникает только тогда, когда сообщение используется и обрабатывается мгновенно.

Может быть какая-то разница во времени на серверах связана с этим или как? Любая помощь будет принята с благодарностью.

...