fix(s3stream): fix namespace (#1977)

Signed-off-by: SSpirits <[email protected]>
AutoMQ · Sep 2, 2024 · dcfef9c · dcfef9c
1 parent 619138b
commit dcfef9c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/kafka/log/streamaspect/ElasticLogManager.scala b/core/src/main/scala/kafka/log/streamaspect/ElasticLogManager.scala
@@ -121,7 +121,8 @@ object ElasticLogManager {
   private var isEnabled = false
 
   def init(config: KafkaConfig, clusterId: String, broker: BrokerServer = null) = {
-    ObjectUtils.setNamespace(Constants.DEFAULT_NAMESPACE + clusterId)
+    NAMESPACE = Constants.DEFAULT_NAMESPACE + clusterId
+    ObjectUtils.setNamespace(NAMESPACE)
 
     val endpoint = config.elasticStreamEndpoint
     if (endpoint == null) {