Closed solita-juusoma closed 2 years ago
Describe the bug ksqlDB always requires the following ACLs for its internal operations and data management:
See documentation: https://docs.ksqldb.io/en/latest/operate-and-deploy/installation/server-config/security/#required-acls
Therefore we need to change method that only introduces topic _confluent-ksql-%s_command_topic:
public String commandTopic() { return String.format("_confluent-ksql-%s_command_topic", ksqlDbId); }
to more common topic _confluent-ksql-%s method:
public String internalTopics() { return String.format("_confluent-ksql-%s", ksqlDbId); }
To Reproduce Steps to reproduce the behavior:
https://github.com/kafka-ops/julie/blob/master/src/main/java/com/purbon/kafka/topology/model/users/platform/KsqlServerInstance.java Only command topic is accessible.
Expected behavior Also Config Topic needs to be accessible.
Runtime (please complete the following information):
Describe the bug ksqlDB always requires the following ACLs for its internal operations and data management:
See documentation: https://docs.ksqldb.io/en/latest/operate-and-deploy/installation/server-config/security/#required-acls
Therefore we need to change method that only introduces topic _confluent-ksql-%s_command_topic:
public String commandTopic() { return String.format("_confluent-ksql-%s_command_topic", ksqlDbId); }
to more common topic _confluent-ksql-%s method:
public String internalTopics() { return String.format("_confluent-ksql-%s", ksqlDbId); }
To Reproduce Steps to reproduce the behavior:
https://github.com/kafka-ops/julie/blob/master/src/main/java/com/purbon/kafka/topology/model/users/platform/KsqlServerInstance.java Only command topic is accessible.
Expected behavior Also Config Topic needs to be accessible.
Runtime (please complete the following information):