diff --git a/kafka-ui-api/src/test/java/com/provectus/kafka/ui/strategy/ksql/statement/CreateStrategyTest.java b/kafka-ui-api/src/test/java/com/provectus/kafka/ui/strategy/ksql/statement/CreateStrategyTest.java index b2d2ee07e2..86e63b1515 100644 --- a/kafka-ui-api/src/test/java/com/provectus/kafka/ui/strategy/ksql/statement/CreateStrategyTest.java +++ b/kafka-ui-api/src/test/java/com/provectus/kafka/ui/strategy/ksql/statement/CreateStrategyTest.java @@ -34,16 +34,16 @@ class CreateStrategyTest { @Test public void shouldReturnTrueInTest() { assertTrue(ksqlStatementStrategy.test("CREATE STREAM stream WITH (KAFKA_TOPIC='topic');")); - assertTrue(ksqlStatementStrategy.test("CREATE STREAM stream" + - " AS SELECT users.id AS userid FROM users EMIT CHANGES;" + assertTrue(ksqlStatementStrategy.test("CREATE STREAM stream" + + " AS SELECT users.id AS userid FROM users EMIT CHANGES;" )); assertTrue(ksqlStatementStrategy.test( "CREATE TABLE table (id VARCHAR) WITH (KAFKA_TOPIC='table');" )); assertTrue(ksqlStatementStrategy.test( - "CREATE TABLE pageviews_regions WITH (KEY_FORMAT='JSON')" + - " AS SELECT gender, COUNT(*) AS numbers" + - " FROM pageviews EMIT CHANGES;" + "CREATE TABLE pageviews_regions WITH (KEY_FORMAT='JSON')" + + " AS SELECT gender, COUNT(*) AS numbers" + + " FROM pageviews EMIT CHANGES;" )); }