public class FlinkZooKeeperQuorumPeer extends Object
QuorumPeer
, which reads a ZooKeeper config file and writes
the required 'myid' file before starting the peer.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_ZOOKEEPER_CLIENT_PORT
ZooKeeper default client port.
|
static int |
DEFAULT_ZOOKEEPER_INIT_LIMIT
ZooKeeper default init limit.
|
static int |
DEFAULT_ZOOKEEPER_LEADER_PORT
ZooKeeper default leader port.
|
static int |
DEFAULT_ZOOKEEPER_PEER_PORT
ZooKeeper default peer port.
|
static int |
DEFAULT_ZOOKEEPER_SYNC_LIMIT
ZooKeeper default sync limit.
|
Constructor and Description |
---|
FlinkZooKeeperQuorumPeer() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args) |
static void |
runFlinkZkQuorumPeer(String zkConfigFile,
int peerId)
Runs a ZooKeeper
QuorumPeer if further peers are configured or a single ZooKeeperServer if no further peers are configured. |
public static final int DEFAULT_ZOOKEEPER_CLIENT_PORT
public static final int DEFAULT_ZOOKEEPER_INIT_LIMIT
public static final int DEFAULT_ZOOKEEPER_SYNC_LIMIT
public static final int DEFAULT_ZOOKEEPER_PEER_PORT
public static final int DEFAULT_ZOOKEEPER_LEADER_PORT
public static void main(String[] args)
public static void runFlinkZkQuorumPeer(String zkConfigFile, int peerId) throws Exception
QuorumPeer
if further peers are configured or a single ZooKeeperServer
if no further peers are configured.zkConfigFile
- ZooKeeper config file 'zoo.cfg'peerId
- ID for the 'myid' fileException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.