CosId-ZooKeeper Module

The cosid-zookeeper module provides support for ZooKeeper. Implements:

• MachineIdDistributor: As the machine ID distributor for Snowflake algorithm (SnowflakeId).
• IdSegmentDistributor: As the segment distributor for segment algorithm (SegmentId).

Installation

Gradle(Kotlin)

    val cosidVersion = "latestVersion"
    implementation("me.ahoo.cosid:cosid-zookeeper:${cosidVersion}")

Maven

    <dependencies>
        <dependency>
            <groupId>me.ahoo.cosid</groupId>
            <artifactId>cosid-zookeeper</artifactId>
            <version>${cosid.version}</version>
        </dependency>
    </dependencies>

Configuration

• Configuration class: CosIdZookeeperProperties
• Prefix: cosid.zookeeper.

Name	Data Type	Description	Default Value
enabled	boolean	Whether to enable ZooKeeper	true
connect-string	String	Connection string	localhost:2181
block-until-connected-wait	Duration	Block until client connected wait time	Duration.ofSeconds(10)
session-timeout	Duration	Session timeout	Duration.ofSeconds(60)
connection-timeout	Duration	Connection timeout	Duration.ofSeconds(15)
retry	Retry	Retry policy configuration

Retry (ExponentialBackoffRetry) Configuration

Name	Data Type	Description	Default Value
baseSleepTimeMs	int	Initial amount of time to wait between retries (milliseconds)	100
maxRetries	int	Maximum number of retries	5
maxSleepMs	int	Maximum sleep time per retry (milliseconds)	500

Configuration Example

CosId-Example-Zookeeper

cosid:
  zookeeper:
    connect-string: localhost:2181
    retry:
      base-sleep-time-ms: 100
      max-retries: 5
      max-sleep-ms: 500
    block-until-connected-wait: 10s
  segment:
    distributor:
      type: zookeeper
  machine:
    distributor:
      type: zookeeper