File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -183,7 +183,8 @@ def kafka_run_class_env(self):
183183 return env
184184
185185 def out (self , message ):
186- log .info ("*** Zookeeper [%s:%s]: %s" , self .host , self .port or '(auto)' , message )
186+ if len (log .handlers ) > 0 :
187+ log .info ("*** Zookeeper [%s:%s]: %s" , self .host , self .port or '(auto)' , message )
187188
188189 def open (self ):
189190 if self .tmp_dir is None :
@@ -381,7 +382,8 @@ def kafka_run_class_env(self):
381382 return env
382383
383384 def out (self , message ):
384- log .info ("*** Kafka [%s:%s]: %s" , self .host , self .port or '(auto)' , message )
385+ if len (log .handlers ) > 0 :
386+ log .info ("*** Kafka [%s:%s]: %s" , self .host , self .port or '(auto)' , message )
385387
386388 def _create_zk_chroot (self ):
387389 self .out ("Creating Zookeeper chroot node..." )
You can’t perform that action at this time.
0 commit comments