org.apache.samza.zk.ZkUtils.incGeneration()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-14 21:23:31 26 4

@Test
public void testShouldRemoveBufferedEventsInDebounceQueueOnSessionExpiration() {
 ZkKeyBuilder keyBuilder = Mockito.mock(ZkKeyBuilder.class);
 ZkClient mockZkClient = Mockito.mock(ZkClient.class);
 when(keyBuilder.getJobModelVersionBarrierPrefix()).thenReturn(TEST_BARRIER_ROOT);
 ZkUtils zkUtils = Mockito.mock(ZkUtils.class);
 when(zkUtils.getKeyBuilder()).thenReturn(keyBuilder);
 when(zkUtils.getZkClient()).thenReturn(mockZkClient);
 when(zkUtils.getJobModel(TEST_JOB_MODEL_VERSION)).thenReturn(new JobModel(new MapConfig(), new HashMap<>()));
 ScheduleAfterDebounceTime mockDebounceTimer = Mockito.mock(ScheduleAfterDebounceTime.class);
 ZkJobCoordinator zkJobCoordinator = Mockito.spy(new ZkJobCoordinator("TEST_PROCESSOR_ID", new MapConfig(), new NoOpMetricsRegistry(), zkUtils));
 zkJobCoordinator.debounceTimer = mockDebounceTimer;
 zkJobCoordinator.zkSessionMetrics = new ZkSessionMetrics(new MetricsRegistryMap());
 final ZkSessionStateChangedListener zkSessionStateChangedListener = zkJobCoordinator.new ZkSessionStateChangedListener();
 zkSessionStateChangedListener.handleStateChanged(Watcher.Event.KeeperState.Expired);
 verify(zkUtils).incGeneration();
 verify(mockDebounceTimer).cancelAllScheduledActions();
 verify(mockDebounceTimer).scheduleAfterDebounceTime(Mockito.eq("ZK_SESSION_EXPIRED"), Mockito.eq(0L), Mockito.any(Runnable.class));
 Assert.assertEquals(1, zkJobCoordinator.zkSessionMetrics.zkSessionExpirations.getCount());
}

zkUtils.incGeneration();

zkUtils.incGeneration();

zkUtils.incGeneration();

zkUtils.incGeneration();

zkUtils.incGeneration();

26 4 0

• kafka.utils.ZkUtils.getReplicasForPartition()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getReplicasForPartition()方法的一些代码示例，展示了ZkUtils.getReplicasForPartition(

• kafka.utils.ZkUtils.getConsumerGroups()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getConsumerGroups()方法的一些代码示例，展示了ZkUtils.getConsumerGroups()的具体用法。这些代码示

• kafka.utils.ZkUtils.zkClient()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.zkClient()方法的一些代码示例，展示了ZkUtils.zkClient()的具体用法。这些代码示例主要来源于Github/Stack

• kafka.utils.ZkUtils.readDataMaybeNull()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.readDataMaybeNull()方法的一些代码示例，展示了ZkUtils.readDataMaybeNull()的具体用法。这些代码示

• kafka.utils.ZkUtils.updatePersistentPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.updatePersistentPath()方法的一些代码示例，展示了ZkUtils.updatePersistentPath()的具体用法

• kafka.utils.ZkUtils.getLeaderForPartition()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getLeaderForPartition()方法的一些代码示例，展示了ZkUtils.getLeaderForPartition()的具体

• kafka.utils.ZkUtils.formatAsReassignmentJson()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.formatAsReassignmentJson()方法的一些代码示例，展示了ZkUtils.formatAsReassignmentJso

• kafka.utils.ZkUtils.getPartitionsForTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionsForTopics()方法的一些代码示例，展示了ZkUtils.getPartitionsForTopics()的

• kafka.utils.ZkUtils.createZkClientAndConnection()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.createZkClientAndConnection()方法的一些代码示例，展示了ZkUtils.createZkClientAndCon

• kafka.utils.ZkUtils.ConsumersPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.ConsumersPath()方法的一些代码示例，展示了ZkUtils.ConsumersPath()的具体用法。这些代码示例主要来源于Gi

• kafka.utils.ZkUtils.getPartitionsBeingReassigned()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionsBeingReassigned()方法的一些代码示例，展示了ZkUtils.getPartitionsBeingR

• kafka.utils.ZkUtils.()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.()方法的一些代码示例，展示了ZkUtils.()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平

• kafka.utils.ZkUtils.apply()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.apply()方法的一些代码示例，展示了ZkUtils.apply()的具体用法。这些代码示例主要来源于Github/Stackoverfl

• kafka.utils.ZkUtils.BrokerIdsPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.BrokerIdsPath()方法的一些代码示例，展示了ZkUtils.BrokerIdsPath()的具体用法。这些代码示例主要来源于Gi

• kafka.utils.ZkUtils.getAllTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getAllTopics()方法的一些代码示例，展示了ZkUtils.getAllTopics()的具体用法。这些代码示例主要来源于Gith

• kafka.utils.ZkUtils.getAllBrokersInCluster()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getAllBrokersInCluster()方法的一些代码示例，展示了ZkUtils.getAllBrokersInCluster()的

• kafka.utils.ZkUtils.getPartitionAssignmentForTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionAssignmentForTopics()方法的一些代码示例，展示了ZkUtils.getPartitionAssi

• kafka.utils.ZkUtils.close()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.close()方法的一些代码示例，展示了ZkUtils.close()的具体用法。这些代码示例主要来源于Github/Stackoverfl

• org.apache.zookeeper.ZKUtil.listSubTreeBFS()方法的使用及代码示例

  本文整理了Java中org.apache.zookeeper.ZKUtil.listSubTreeBFS()方法的一些代码示例，展示了ZKUtil.listSubTreeBFS()的具体用法。这些代码

• com.facebook.zookeeper.ZkUtil.bytesToString()方法的使用及代码示例

  本文整理了Java中com.facebook.zookeeper.ZkUtil.bytesToString()方法的一些代码示例，展示了ZkUtil.bytesToString()的具体用法。这些代码