We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 29670da commit 1c7e887Copy full SHA for 1c7e887
src/test/java/org/akhq/clusters/EmbeddedSingleNodeKafkaCluster.java
@@ -105,6 +105,7 @@ public void start() throws Exception {
105
ksqlDbProperties.put("bootstrap.servers", bootstrapServers());
106
ksqlDbProperties.put("ksql.schema.registry.url", schemaRegistryUrl());
107
ksqlDbProperties.put("listeners", "http://0.0.0.0:" + randomPort());
108
+ ksqlDbProperties.put("ksql.udf.enable.security.manager", "false");
109
110
ksqlDBEmbedded = new KsqlDBEmbedded(ksqlDbProperties);
111
log.debug("Kafka KsqlDB is running at {}", ksqlDbUrl());
0 commit comments