@Test public void testGetPartitionId() { assertEquals(partitionId, simpleConsumer.getPartitionId()); }
public int getPartitionId() { return topicAndPartition.getPartitionId(); }
SimpleConsumer { public int getPartitionId() { return topicAndPartition.getPartitionId(); } }
SimpleConsumer { public int getPartitionId() { return topicAndPartition.getPartitionId(); } SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient);  SimpleConsumer(TalosConsumerConfig consumerConfig, String topicName,
      int partitionId, Credential credential); @Deprecated  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, Credential credential);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      String topicName, int partitionId, TalosClientFactory talosClientFactory,
      String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      MessageService.Iface messageClient, String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory);  SimpleConsumer(TalosConsumerConfig consumerConfig, String topicName,
      int partitionId, MessageService.Iface messageClient,
      TopicService.Iface topicClient,
      ScheduleInfoCache scheduleInfoCacheMock); }
SimpleConsumer { public int getPartitionId() { return topicAndPartition.getPartitionId(); } SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient);  SimpleConsumer(TalosConsumerConfig consumerConfig, String topicName,
      int partitionId, Credential credential); @Deprecated  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, Credential credential);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      String topicName, int partitionId, TalosClientFactory talosClientFactory,
      String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      MessageService.Iface messageClient, String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory);  SimpleConsumer(TalosConsumerConfig consumerConfig, String topicName,
      int partitionId, MessageService.Iface messageClient,
      TopicService.Iface topicClient,
      ScheduleInfoCache scheduleInfoCacheMock); TopicTalosResourceName getTopicTalosResourceName(); void setSimpleConsumerId(String simpleConsumerId); String getSimpleConsumerId(); int getPartitionId(); TopicAndPartition getTopicAndPartition(); List<MessageAndOffset> fetchMessage(long startOffset); List<MessageAndOffset> fetchMessage(long startOffset,
      int maxFetchedNumber); void shutDown(); }
SimpleConsumer { public int getPartitionId() { return topicAndPartition.getPartitionId(); } SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient);  SimpleConsumer(TalosConsumerConfig consumerConfig, String topicName,
      int partitionId, Credential credential); @Deprecated  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, Credential credential);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      String topicName, int partitionId, TalosClientFactory talosClientFactory,
      String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      MessageService.Iface messageClient, String consumerIdPrefix);  SimpleConsumer(TalosConsumerConfig consumerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory);  SimpleConsumer(TalosConsumerConfig consumerConfig, String topicName,
      int partitionId, MessageService.Iface messageClient,
      TopicService.Iface topicClient,
      ScheduleInfoCache scheduleInfoCacheMock); TopicTalosResourceName getTopicTalosResourceName(); void setSimpleConsumerId(String simpleConsumerId); String getSimpleConsumerId(); int getPartitionId(); TopicAndPartition getTopicAndPartition(); List<MessageAndOffset> fetchMessage(long startOffset); List<MessageAndOffset> fetchMessage(long startOffset,
      int maxFetchedNumber); void shutDown();  }