test_class.declarator: zooKeeper = new EmbeddedZooKeeper()
test_class.modifier: @Rule
      public
test_class.original_string: @Rule
      public EmbeddedZooKeeper zooKeeper = new EmbeddedZooKeeper();
test_class.type: EmbeddedZooKeeper
test_class.var_name: zooKeeper
test_class.declarator: broker = EmbeddedKafkaBroker.builder()
              .zookeeperConnect("127.0.0.1:" + zooKeeper.getPort())
              //.logFlushIntervalMessages(1)
              .build()
test_class.modifier: @Rule
      public
test_class.original_string: @Rule
      public EmbeddedKafkaBroker broker = EmbeddedKafkaBroker.builder()
              .zookeeperConnect("127.0.0.1:" + zooKeeper.getPort())
              //.logFlushIntervalMessages(1)
              .build();
test_class.type: EmbeddedKafkaBroker
test_class.var_name: broker
test_class.file: kafka/kafka-perf-tool/src/test/java/com/ameliant/tools/kafka/perftool/drivers/ConsumerDriverTest.java
test_class.identifier: ConsumerDriverTest
test_case.body: @Test
      public void testReceive_sequential() throws InterruptedException {
          String topic = "foo";
          int messageCount = 1000;
  
          CountDownLatch latch = new CountDownLatch(2);
  
          // fill up the topic
          ProducerDriver producerDriver = createProducerDriver(latch, topic, messageCount);
          producerDriver.run();
  
          ConsumerDriver consumerDriver = createConsumerDriver(latch, topic, messageCount);
          consumerDriver.run();
  
          assertEquals(messageCount, consumerDriver.getMessagesReceived());
      }
test_case.class_method_signature: ConsumerDriverTest.testReceive_sequential()
test_case.full_signature: @Test public void testReceive_sequential()
test_case.identifier: testReceive_sequential
test_case.invocations: createProducerDriver run createConsumerDriver run assertEquals getMessagesReceived
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testReceive_sequential()
focal_class.declarator: consumerDefinition
focal_class.modifier: private final
focal_class.original_string: private final ConsumerDefinition consumerDefinition;
focal_class.type: ConsumerDefinition
focal_class.var_name: consumerDefinition
focal_class.declarator: completionLatch
focal_class.modifier: private
focal_class.original_string: private CountDownLatch completionLatch;
focal_class.type: CountDownLatch
focal_class.var_name: completionLatch
focal_class.declarator: recordsFetched = 0
focal_class.modifier: private
focal_class.original_string: private long recordsFetched = 0;
focal_class.type: long
focal_class.var_name: recordsFetched
focal_class.declarator: consumerRebalanceListener
focal_class.modifier: private
focal_class.original_string: private ConsumerRebalanceListener consumerRebalanceListener;
focal_class.type: ConsumerRebalanceListener
focal_class.var_name: consumerRebalanceListener
focal_class.file: kafka/kafka-perf-tool/src/main/java/com/ameliant/tools/kafka/perftool/drivers/ConsumerDriver.java
focal_class.identifier: ConsumerDriver
focal_class.class_method_signature: ConsumerDriver.setConsumerRebalanceListener(ConsumerRebalanceListener consumerRebalanceListener)
focal_class.full_signature: public void setConsumerRebalanceListener(ConsumerRebalanceListener consumerRebalanceListener)
focal_class.identifier: setConsumerRebalanceListener
focal_class.modifiers: public
focal_class.parameters: (ConsumerRebalanceListener consumerRebalanceListener)
focal_class.return: void
focal_class.signature: void setConsumerRebalanceListener(ConsumerRebalanceListener consumerRebalanceListener)
focal_class.class_method_signature: ConsumerDriver.ConsumerDriver(ConsumerDefinition consumerDefinition)
focal_class.full_signature: public  ConsumerDriver(ConsumerDefinition consumerDefinition)
focal_class.identifier: ConsumerDriver
focal_class.modifiers: public
focal_class.parameters: (ConsumerDefinition consumerDefinition)
focal_class.signature:  ConsumerDriver(ConsumerDefinition consumerDefinition)
focal_class.class_method_signature: ConsumerDriver.ConsumerDriver(ConsumerDefinition consumerDefinition, CountDownLatch completionLatch)
focal_class.full_signature: public  ConsumerDriver(ConsumerDefinition consumerDefinition, CountDownLatch completionLatch)
focal_class.identifier: ConsumerDriver
focal_class.modifiers: public
focal_class.parameters: (ConsumerDefinition consumerDefinition, CountDownLatch completionLatch)
focal_class.signature:  ConsumerDriver(ConsumerDefinition consumerDefinition, CountDownLatch completionLatch)
focal_class.class_method_signature: ConsumerDriver.drive()
focal_class.full_signature: @Override public void drive()
focal_class.identifier: drive
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void drive()
focal_class.class_method_signature: ConsumerDriver.applyReceiveDelay()
focal_class.full_signature: private void applyReceiveDelay()
focal_class.identifier: applyReceiveDelay
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void applyReceiveDelay()
focal_class.class_method_signature: ConsumerDriver.getMessagesReceived()
focal_class.full_signature: public long getMessagesReceived()
focal_class.identifier: getMessagesReceived
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getMessagesReceived()
focal_class.class_method_signature: ConsumerDriver.getMessagesExpected()
focal_class.full_signature: public long getMessagesExpected()
focal_class.identifier: getMessagesExpected
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getMessagesExpected()
focal_class.superclass: extends Driver
focal_method.body: public long getMessagesReceived() {
          return recordsFetched;
      }
focal_method.class_method_signature: ConsumerDriver.getMessagesReceived()
focal_method.full_signature: public long getMessagesReceived()
focal_method.identifier: getMessagesReceived
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: long
focal_method.signature: long getMessagesReceived()