ClusterConfiguration constructor

Initializes a new instance of the ClusterConfiguration class.

public ClusterConfiguration(KafkaConfiguration kafka, string name, IEnumerable<string> brokers, 
    Func<SecurityInformation> securityInformationHandler, 
    Action<IDependencyResolver> onStartedHandler, Action<IDependencyResolver> onStoppingHandler, 
    IEnumerable<TopicConfiguration> topicsToCreateIfNotExist = null)

parameter	description
kafka	The kafka configuration
name	The cluster name
brokers	The list of brokers
securityInformationHandler	The security information handler
onStartedHandler	The handler to be executed when the cluster started
onStoppingHandler	The handler to be executed when the cluster is stopping
topicsToCreateIfNotExist	Topics to create on startup if not exists

See Also

• class KafkaConfiguration
• class TopicConfiguration
• class ClusterConfiguration
• namespace KafkaFlow.Configuration