diff --git a/plugins/database/cassandra/connection_producer.go b/plugins/database/cassandra/connection_producer.go index 44b0b7d5c6ba..45d46518b6d0 100644 --- a/plugins/database/cassandra/connection_producer.go +++ b/plugins/database/cassandra/connection_producer.go @@ -228,7 +228,7 @@ func (c *cassandraConnectionProducer) createSession() (*gocql.Session, error) { } // Verify the info - err = session.Query(`LIST USERS`).Exec() + err = session.Query(`LIST ALL`).Exec() if err != nil { return nil, fmt.Errorf("error validating connection info: %s", err) }