diff --git a/src/v/cluster/partition.cc b/src/v/cluster/partition.cc index 8350845f7d95..806c69a19a7e 100644 --- a/src/v/cluster/partition.cc +++ b/src/v/cluster/partition.cc @@ -187,59 +187,6 @@ raft::replicate_stages partition::replicate_in_stages( } } -ss::future> partition::replicate( - model::batch_identity bid, - model::record_batch_reader&& r, - raft::replicate_options opts) { - if (bid.is_transactional) { - if (!_is_tx_enabled) { - vlog( - clusterlog.error, - "Can't process a transactional request to {}. Transactional " - "processing isn't enabled.", - _raft->ntp()); - return ss::make_ready_future>( - raft::errc::timeout); - } - - if (!_rm_stm) { - vlog( - clusterlog.error, - "Topic {} doesn't support transactional processing.", - _raft->ntp()); - return ss::make_ready_future>( - raft::errc::timeout); - } - } - - if (bid.has_idempotent()) { - if (!_is_idempotence_enabled) { - vlog( - clusterlog.error, - "Can't process an idempotent request to {}. Idempotency isn't " - "enabled.", - _raft->ntp()); - return ss::make_ready_future>( - raft::errc::timeout); - } - - if (!_rm_stm) { - vlog( - clusterlog.error, - "Topic {} doesn't support idempotency.", - _raft->ntp()); - return ss::make_ready_future>( - raft::errc::timeout); - } - } - - if (_rm_stm) { - return _rm_stm->replicate(bid, std::move(r), opts); - } else { - return _raft->replicate(std::move(r), opts); - } -} - ss::future<> partition::start() { auto ntp = _raft->ntp(); diff --git a/src/v/cluster/partition.h b/src/v/cluster/partition.h index 81107c6d0beb..e62c856e1b51 100644 --- a/src/v/cluster/partition.h +++ b/src/v/cluster/partition.h @@ -59,11 +59,6 @@ class partition { ss::future> replicate( model::term_id, model::record_batch_reader&&, raft::replicate_options); - ss::future> replicate( - model::batch_identity, - model::record_batch_reader&&, - raft::replicate_options); - raft::replicate_stages replicate_in_stages( model::batch_identity, model::record_batch_reader&&,