@Test public void testGetTopicAndPartition() { assertEquals(topicAndPartition, simpleConsumer.getTopicAndPartition()); }
public TopicAndPartition getTopicAndPartition() { return topicAndPartition; }
SimpleConsumer { public TopicAndPartition getTopicAndPartition() { return topicAndPartition; } }
SimpleConsumer { public TopicAndPartition getTopicAndPartition() { return topicAndPartition; } 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 TopicAndPartition getTopicAndPartition() { return topicAndPartition; } 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 TopicAndPartition getTopicAndPartition() { return topicAndPartition; } 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();  }