diff --git a/client/src/components/Form/Form.jsx b/client/src/components/Form/Form.jsx
index 71afd3570..24601e557 100644
--- a/client/src/components/Form/Form.jsx
+++ b/client/src/components/Form/Form.jsx
@@ -112,7 +112,7 @@ class Form extends Root {
     );
   };
 
-  renderJSONInput = (name, label, onChange, textMode, options) => {
+  renderJSONInput = (name, label, onChange, textMode, options, rest) => {
     const { formData, errors } = this.state;
     const inputMode = textMode ? "text" : (formData.schemaType === "PROTOBUF" ? "protobuf"  : "json")
     return (
@@ -137,6 +137,7 @@ class Form extends Root {
             editorProps={{ $blockScrolling: true }}
             setOptions={options}
             style={{ width: '100%', minHeight: '25vh' }}
+            {...rest}
           />
           {errors[name] && <div className="alert alert-danger mt-1 p-1">{errors[name]}</div>}
         </div>
@@ -241,7 +242,7 @@ class Form extends Root {
     );
   };
 
-  renderCheckbox = (name, label, isChecked, onChange, isDefaultChecked) => {
+  renderCheckbox = (name, label, isChecked, onChange, isDefaultChecked, rest) => {
     return (
         <input
         type="checkbox"
@@ -251,6 +252,7 @@ class Form extends Root {
         checked={isChecked}
         onChange={onChange}
         defaultChecked={ isDefaultChecked ? isDefaultChecked : false}
+        {...rest}
         />
     );
   };
diff --git a/client/src/containers/Topic/TopicProduce/TopicProduce.jsx b/client/src/containers/Topic/TopicProduce/TopicProduce.jsx
index 61d863899..1850d5b0c 100644
--- a/client/src/containers/Topic/TopicProduce/TopicProduce.jsx
+++ b/client/src/containers/Topic/TopicProduce/TopicProduce.jsx
@@ -47,6 +47,7 @@ class TopicProduce extends Form {
     topics: [],
     topicsSearchValue: '',
     multiMessage: false,
+    tombstone: false,
     valuePlaceholder: '{"param": "value"}'
   };
 
@@ -157,12 +158,19 @@ class TopicProduce extends Form {
       selectedValueSchema,
       keySchema,
       valueSchema,
-      multiMessage
+      multiMessage,
+      tombstone
     } = this.state;
     const { clusterId } = this.props.match.params;
 
     let schemaKeyToSend = keySchema.find(key => key.subject === selectedKeySchema);
     let schemaValueToSend = valueSchema.find(value => value.subject === selectedValueSchema);
+    let value;
+    if (tombstone) {
+      value = null;
+    } else {
+      value = multiMessage ? formData.value : JSON.parse(JSON.stringify(formData.value))
+    }
     const topic = {
       clusterId,
       topicId,
@@ -170,7 +178,7 @@ class TopicProduce extends Form {
       partition: formData.partition,
       key: formData.key,
       timestamp: datetime.toISOString(),
-      value: multiMessage ? formData.value : JSON.parse(JSON.stringify(formData.value)),
+      value: value,
       keySchema: schemaKeyToSend ? schemaKeyToSend.id : '',
       valueSchema: schemaValueToSend ? schemaValueToSend.id : '',
       multiMessage: multiMessage,
@@ -196,7 +204,7 @@ class TopicProduce extends Form {
       });
   }
 
-  renderMultiMessage() {
+  renderMultiMessage(tombstone) {
     const { formData, multiMessage } = this.state;
 
     return (
@@ -211,7 +219,8 @@ class TopicProduce extends Form {
                 this.setState({multiMessage: !multiMessage,
                   valuePlaceholder: this.getPlaceholderValue(!multiMessage, formData.keyValueSeparator)})
               },
-              false
+              false,
+              { disabled: tombstone }
             )}
 
             <label className="col-auto col-form-label">Separator</label>
@@ -236,6 +245,28 @@ class TopicProduce extends Form {
     );
   }
 
+  renderTombstone(multiMessage) {
+    const { tombstone } = this.state;
+
+    return (
+        <div className="form-group row">
+          <label className="col-sm-2 col-form-label">Tombstone</label>
+          <div className="row khq-multiple col-sm-7">
+            {this.renderCheckbox(
+                'isTombstone',
+                '',
+                tombstone,
+                () => {
+                  this.setState({tombstone: !tombstone} )
+                },
+                false,
+                { disabled: multiMessage }
+            )}
+          </div>
+        </div>
+    );
+  }
+
   getPlaceholderValue(isMultiMessage, keyValueSeparator) {
     if(isMultiMessage) {
       return 'key1' + keyValueSeparator + '{"param": "value1"}\n'
@@ -403,7 +434,8 @@ class TopicProduce extends Form {
       valueSchema,
       valueSchemaSearchValue,
       selectedValueSchema,
-      multiMessage
+      multiMessage,
+      tombstone
     } = this.state;
     let date = moment(datetime);
     return (
@@ -472,7 +504,9 @@ class TopicProduce extends Form {
             )
           )}
 
-          {this.renderMultiMessage()}
+          {this.renderMultiMessage(tombstone)}
+
+          {this.renderTombstone(multiMessage)}
 
           {this.renderJSONInput('value', 'Value', value => {
             this.setState({
@@ -482,7 +516,8 @@ class TopicProduce extends Form {
                 }
             })},
           multiMessage, // true -> 'text' mode; json, protobuff, ... mode otherwise
-          { placeholder: this.getPlaceholderValue(multiMessage, formData.keyValueSeparator) }
+          { placeholder: this.getPlaceholderValue(multiMessage, formData.keyValueSeparator) },
+          { readOnly: tombstone }
           )}
           <div style={{ display: 'flex', flexDirection: 'row', width: '100%', padding: 0 }}>
             <label
diff --git a/src/main/java/org/akhq/controllers/TopicController.java b/src/main/java/org/akhq/controllers/TopicController.java
index 8c2bcaa59..ffb3ca36d 100644
--- a/src/main/java/org/akhq/controllers/TopicController.java
+++ b/src/main/java/org/akhq/controllers/TopicController.java
@@ -140,7 +140,7 @@ public List<Record> produce(
         HttpRequest<?> request,
         String cluster,
         String topicName,
-        String value,
+        Optional<String> value,
         Optional<String> key,
         Optional<Integer> partition,
         Optional<String> timestamp,
@@ -167,7 +167,7 @@ public List<Record> produce(
                     .map(recordMetadata -> new Record(recordMetadata,
                             schemaRegistryRepository.getSchemaRegistryType(cluster),
                             key.map(String::getBytes).orElse(null),
-                            value.getBytes(),
+                            value.map(String::getBytes).orElse(null),
                             headers,
                             targetTopic))
                     .collect(Collectors.toList());
diff --git a/src/main/java/org/akhq/repositories/RecordRepository.java b/src/main/java/org/akhq/repositories/RecordRepository.java
index 3577de47e..f9a07b6ef 100644
--- a/src/main/java/org/akhq/repositories/RecordRepository.java
+++ b/src/main/java/org/akhq/repositories/RecordRepository.java
@@ -479,7 +479,7 @@ private Record newRecord(ConsumerRecord<byte[], byte[]> record, BaseOptions opti
     public List<RecordMetadata> produce(
             String clusterId,
             String topic,
-            String value,
+            Optional<String> value,
             Map<String, String> headers,
             Optional<String> key,
             Optional<Integer> partition,
@@ -492,10 +492,10 @@ public List<RecordMetadata> produce(
         List<RecordMetadata> produceResults = new ArrayList<>();
 
         // Distinguish between single record produce, and multiple messages
-        if (multiMessage.booleanValue()) {
+        if (Boolean.TRUE.equals(multiMessage) && value.isPresent()) {
             // Split key-value pairs and produce them
-            for (KeyValue<String, String> kvPair : splitMultiMessage(value, keyValueSeparator.orElseThrow())) {
-                produceResults.add(produce(clusterId, topic, kvPair.getValue(), headers, Optional.of(kvPair.getKey()),
+            for (KeyValue<String, String> kvPair : splitMultiMessage(value.get(), keyValueSeparator.orElseThrow())) {
+                produceResults.add(produce(clusterId, topic, Optional.of(kvPair.getValue()), headers, Optional.of(kvPair.getKey()),
                         partition, timestamp, keySchemaId, valueSchemaId));
             }
         } else {
@@ -590,7 +590,7 @@ private void deleteRecords(String clusterId, Map<TopicPartition, RecordsToDelete
     public RecordMetadata produce(
         String clusterId,
         String topic,
-        String value,
+        Optional<String> value,
         Map<String, String> headers,
         Optional<String> key,
         Optional<Integer> partition,
@@ -610,7 +610,7 @@ public RecordMetadata produce(
             }
         } else {
             try {
-                if (Topic.isCompacted(configRepository.findByTopic(clusterId, value))) {
+                if (Topic.isCompacted(configRepository.findByTopic(clusterId, value.isEmpty() ? null : value.get()))) {
                     throw new IllegalArgumentException("Key missing for produce onto compacted topic");
                 }
             } catch (ExecutionException ex) {
@@ -618,11 +618,11 @@ public RecordMetadata produce(
             }
         }
 
-        if (value != null && valueSchemaId.isPresent()) {
+        if (value.isPresent() && valueSchemaId.isPresent()) {
             SchemaSerializer valueSerializer = serializerFactory.createSerializer(clusterId, valueSchemaId.get());
-            valueAsBytes = valueSerializer.serialize(value);
+            valueAsBytes = valueSerializer.serialize(value.get());
         } else {
-            valueAsBytes = value != null ? value.getBytes() : null;
+            valueAsBytes = value.map(String::getBytes).orElse(null);
         }
 
         return produce(clusterId, topic, valueAsBytes, headers, keyAsBytes, partition, timestamp);
diff --git a/src/test/java/org/akhq/controllers/TopicControllerTest.java b/src/test/java/org/akhq/controllers/TopicControllerTest.java
index 576280f4f..fe4da46cb 100644
--- a/src/test/java/org/akhq/controllers/TopicControllerTest.java
+++ b/src/test/java/org/akhq/controllers/TopicControllerTest.java
@@ -193,6 +193,22 @@ void produce() {
         assertEquals("1", response.get(0).getHeaders().get("my-header-1"));
     }
 
+    @Test
+    @Order(3)
+    void produceTombstone() {
+        Map<String, Object> paramMap = new HashMap<>();
+        paramMap.put("value", null);
+        paramMap.put("key", "my-key-tomb");
+        paramMap.put("multiMessage", false);
+        List<Record> response = this.retrieveList(HttpRequest.POST(
+            CREATE_TOPIC_URL + "/data", paramMap
+        ), Record.class);
+
+        assertEquals(1, response.size());
+        assertEquals("my-key-tomb", response.get(0).getKey());
+        assertNull(response.get(0).getValue());
+    }
+
     @Test
     @Order(4)
     void dataGet() {
@@ -214,7 +230,7 @@ void dataDelete() {
             ),
             Record.class
         );
-        assertEquals(1, retrieve.getOffset());
+        assertEquals(2, retrieve.getOffset());
 
         // get data
         // @TODO: Failed to see the message
diff --git a/src/test/java/org/akhq/repositories/RecordRepositoryTest.java b/src/test/java/org/akhq/repositories/RecordRepositoryTest.java
index d8451559d..9bf7b10f6 100644
--- a/src/test/java/org/akhq/repositories/RecordRepositoryTest.java
+++ b/src/test/java/org/akhq/repositories/RecordRepositoryTest.java
@@ -250,7 +250,7 @@ void produceAndConsumeRecordUsingJsonSchema() throws ExecutionException, Interru
         RecordMetadata producedRecordMetadata = repository.produce(
             KafkaTestCluster.CLUSTER_ID,
             KafkaTestCluster.TOPIC_JSON_SCHEMA,
-            recordAsJsonString,
+            Optional.of(recordAsJsonString),
             Collections.emptyMap(),
             Optional.of(keyJsonString),
             Optional.empty(),