apache-kafka - Cassandra 模板正在更新 cassandra 表的特定整数列，但在 DB 中它不反映更新的值

Question

在我的春季 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);
    }

此外，如果我让消费者​​失望并让消息堆积在主题中，然后如果我重新启动消费者，那么所有堆积的消息都会得到很好的处理。仅当消息被立即使用和处理时才会发生问题。

服务器中的一些时差可能是这个还是什么？任何帮助将不胜感激。

标签： apache-kafkacassandraspring-kafka