diff --git a/kafka-rest/src/main/java/io/confluent/kafkarest/resources/v2/PartitionsResource.java b/kafka-rest/src/main/java/io/confluent/kafkarest/resources/v2/PartitionsResource.java index 505452562b..4c15a92f18 100644 --- a/kafka-rest/src/main/java/io/confluent/kafkarest/resources/v2/PartitionsResource.java +++ b/kafka-rest/src/main/java/io/confluent/kafkarest/resources/v2/PartitionsResource.java @@ -194,14 +194,7 @@ protected void produce( final int partition, final EmbeddedFormat format, final ProduceRequest request - ) throws Exception { - // If the topic already exists, we can proactively check for the partition - if (topicExists(topic)) { - if (!ctx.getAdminClientWrapper().partitionExists(topic, partition)) { - throw Errors.partitionNotFoundException(); - } - } - + ) { log.trace( "Executing topic produce request id={} topic={} partition={} format={} request={}", asyncResponse, topic, partition, format, request