因此，我的问题可能涉及一些头脑风暴的基础上的性质的应用程序。
我有一个node js应用程序，可以向kafka发送消息。例如，每次用户单击页面时，Kafka应用程序都会根据访问量运行一个计算。然后，在同一个示例中，我希望在通过kafka消息触发计算之后检索它。到目前为止，这个计算存储在一个cassandra数据库中。问题是，如果我们试图在计算完成之前从cassandra读取数据，那么我们将不会从数据库中查询任何内容（尚未插入密钥），也不会返回任何内容（错误），或者可能是计算已过时。这是我目前的代码。

router.get('/:slug', async (req, res) =>{

Producer = kafka.Producer

KeyedMessage = kafka.KeyedMessage
  client = new kafka.KafkaClient()

producer = new Producer(client)

km = new KeyedMessage('key', 'message')
  kafka_message = JSON.stringify({ id: req.session.session_id.toString(), url: arbitrary_url })
  payloads = [
    { topic: 'MakeComputationTopic', messages: kafka_message}
  ]; 
const clientCass = new cassandra.Client({
contactPoints: ['127.0.0.1:9042'],
localDataCenter: 'datacenter1', // here is the change required
keyspace: 'computation_space',
authProvider: new auth.PlainTextAuthProvider('cassandra', 'cassandra')
});

const query = 'SELECT * FROM computation  WHERE id = ?';

clientCass.execute(query, [req.session.session_id],{ hints : ['int'] })
  .then(result => console.log('User with email %s', result.rows[0].computations))
  .catch((message) => {
    console.log('Could not find key')
  });

}

首先，async和await出现在我的脑海中，但这是被排除的，因为这不会停止陈旧的计算。
第二，我考虑让我的应用程序休眠，但这种方式似乎会减慢我的应用程序。
我可能决定使用kafka consumer（在我的node js中）来使用一条消息，该消息指示现在可以安全地查看cassandra表。
例如（使用Kafka节点）

consumer.on('message', function (message) {
    clientCass.execute(query, [req.session.session_id],{ hints : ['int'] })
  .then(result => console.log('User with computation%s', result.rows[0].computations))
  .catch((message) => {
    console.log('Could not find key')
  });
});

这种方法虽然更好，但似乎有点不合适，因为每次用户单击一个页面时，我都必须让一个消费者，我只关心它被发送一条消息。
我在想我该如何应对这个挑战？我可能错过了一个场景，或者有没有一种方法可以使用kafka节点来解决这个问题？我还考虑做一个while循环，等待承诺成功，并且计算不会过时（比较缓存中的值）