[GitHub] [incubator-openwhisk] YangZhou1997 commented on issue #4473: Is there any periodical heartbeat checking between controller and multiple invokers?

[GitBox <gi...@apache.org>]

YangZhou1997 commented on issue #4473: Is there any periodical heartbeat checking between controller and multiple invokers? 
URL: https://github.com/apache/incubator-openwhisk/issues/4473#issuecomment-490355829
 
 
   Thanks for the comments! 
   One puzzle I remained is how to create a new topic and specify the topic parameters in Kafka. 
   
   I went through the controller source code and find msgProvider.ensureTopic() in KafkaMessagingProvider.scala creates topics in Kafka. But I find it hard to figure out how loadConfigOrThrow() in KafkaMessagingProvider.scala is implemented. Does it read the configuration file from zookeeper or locally? 
   
   The thing is that: when I tried to create a new topic (ie, new topic name) using msgProvider.ensureTopic(), the logs in controller show that the configuration mapping for the new topic is not found and crashes the controller. 

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services