diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/strategy/ksql/statement/ShowStrategy.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/strategy/ksql/statement/ShowStrategy.java index 1b80c6648b..1a2250e850 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/strategy/ksql/statement/ShowStrategy.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/strategy/ksql/statement/ShowStrategy.java @@ -1,6 +1,7 @@ package com.provectus.kafka.ui.strategy.ksql.statement; import com.fasterxml.jackson.databind.JsonNode; +import com.provectus.kafka.ui.model.KsqlCommand; import com.provectus.kafka.ui.model.KsqlCommandResponse; import java.util.List; import java.util.Optional; @@ -36,6 +37,15 @@ public class ShowStrategy extends BaseStrategy { return ""; } + @Override + public BaseStrategy ksqlCommand(KsqlCommand ksqlCommand) { + // return new instance to avoid conflicts for parallel requests + ShowStrategy clone = new ShowStrategy(); + clone.setResponseValueKey(responseValueKey); + clone.ksqlCommand = ksqlCommand; + return clone; + } + protected String getShowRegExp(String key) { return "show " + key + ";"; }