connect
Connect to an Apache Kafka cluster.
Use connect to associate your MSGMX session with an Apache Kafka cluster containing one or more Apache ZooKeeper and/or Quorum nodes and Apache Kafka Brokers. To be able to do this, the target service must be running, and an accessible IP address must be supplied.
Synopsis
connect <ClusterName> <host:port> [ command-config <File> ]
Required Arguments
address:port
. For Apache Kafka versions 2.7.0 and later, only one Apache ZooKeeper host argument is required, provided the Apache Zookeepers supporting the Kafka cluster are configured per Apache ZooKeeper Dynamic Reconfiguration practices. For more information, see the Zookeeper Dynamic Reconfiguration documentation. However, you can optionally provide additional host arguments for the other Apache ZooKeepers in the cluster, and MSGMX will try to connect to them in the order specified until it achieves a successful connection. In either case, once a connection has been made to a single Apache ZooKeeper, MSGMX can obtain the connection information for all of the other ZooKeeper nodes in that ZooKeeper cluster when using Apache Kafka 2.7.0 or later.
Optional Arguments
Examples
> connect myCluster1 localhost:2181
> connect myCluster2 localhost:2181 localhost:2182 localhost:2183 command-config my_cred_file