diff --git a/transport/server.cc b/transport/server.cc index 2225660438..61dda44743 100644 --- a/transport/server.cc +++ b/transport/server.cc @@ -921,6 +921,7 @@ future<> cql_server::connection::write_result(int16_t stream, shared_ptr cql_server::connection::write_schema_change_event(const transport::event::schema_change& event) { auto response = make_shared(-1, cql_binary_opcode::EVENT); + response->write_string("SCHEMA_CHANGE"); response->write_string(to_string(event.change)); response->write_string(to_string(event.target)); response->write_string(event.keyspace);