diff --git a/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java b/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java index 55523475eb0..312b0b237a5 100644 --- a/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java +++ b/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java @@ -1566,7 +1566,6 @@ private ColumnDefinition getDefinition(@NotNull final Properties consumerProp } else { result = definitionFactory.apply(commonColumnName); } - consumerProperties.remove(nameProperty); } else if (nameDefault == null) { result = null; } else {