private final ZoneId zoneId;
private final int numShards;
private final Duration pollingInterval;
private final ZoneId zoneId;
private final int numShards;
private final Duration pollingInterval;
private final Clock clock;
private final boolean[] isShardOwned;
private final long[] currentOffset;
private final Clock clock;
private final boolean[] isShardOwned;
private final long[] currentOffset;
Clock clock,
ChannelMediator channelMediator,
ShardingPublisherStrategy shardingPublisherStrategy)
Clock clock,
ChannelMediator channelMediator,
ShardingPublisherStrategy shardingPublisherStrategy)