diff --git a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java index d092b06be2..d1ca057658 100644 --- a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java +++ b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java @@ -729,7 +729,8 @@ private ApiError createTopic(ControllerRequestContext context, Map creationConfigs = translateCreationConfigs(topic.configs()); Map newParts = new HashMap<>(); - boolean inklessEnabled = Boolean.parseBoolean(creationConfigs.getOrDefault(INKLESS_ENABLE_CONFIG, "" + defaultInklessEnable)); + boolean inklessEnabledByDefault = defaultInklessEnable && !Topic.isInternal(topic.name()); + boolean inklessEnabled = Boolean.parseBoolean(creationConfigs.getOrDefault(INKLESS_ENABLE_CONFIG, "" + inklessEnabledByDefault)); if (inklessEnabled) { if (Math.abs(topic.replicationFactor()) != 1) { return new ApiError(Errors.INVALID_REPLICATION_FACTOR,