diff --git a/src/v/kafka/server/handlers/produce.cc b/src/v/kafka/server/handlers/produce.cc index d4eb6dba682e..cf68e87d2f39 100644 --- a/src/v/kafka/server/handlers/produce.cc +++ b/src/v/kafka/server/handlers/produce.cc @@ -25,7 +25,6 @@ #include "model/timestamp.h" #include "raft/errc.h" #include "raft/types.h" -#include "storage/shard_assignment.h" #include "utils/remote.h" #include "utils/to_string.h" #include "vlog.h" diff --git a/src/v/storage/shard_assignment.h b/src/v/storage/shard_assignment.h deleted file mode 100644 index e4296a2a4da9..000000000000 --- a/src/v/storage/shard_assignment.h +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Copyright 2020 Redpanda Data, Inc. - * - * Use of this software is governed by the Business Source License - * included in the file licenses/BSL.md - * - * As of the Change Date specified in that file, in accordance with - * the Business Source License, use of this software will be governed - * by the Apache License, Version 2.0 - */ - -#pragma once - -#include "hashing/jump_consistent_hash.h" -#include "hashing/xx.h" -#include "model/fundamental.h" -#include "seastarx.h" - -#include - -namespace storage { - -inline ss::shard_id shard_of(const model::ntp& ntp) { - incremental_xxhash64 inc; - inc.update(ntp.ns()); - inc.update(ntp.tp.topic()); - auto p = ntp.tp.partition(); - inc.update((const char*)&p, sizeof(model::partition_id::type)); - return jump_consistent_hash(inc.digest(), ss::smp::count); -} - -} // namespace storage