Remove duplicated test since the last rebase

Author: artembilan

spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java

@@ -172,60 +172,6 @@ public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
 		logger.info("Stop auto");
 	}
 
-	@Test
-	public void testAutoCommitWithRebalanceListener() throws Exception {
-		logger.info("Start auto");
-		Map<String, Object> props = KafkaTestUtils.consumerProps("test10", "true", embeddedKafka);
-		DefaultKafkaConsumerFactory<Integer, String> cf = new DefaultKafkaConsumerFactory<Integer, String>(props);
-		ConcurrentMessageListenerContainer<Integer, String> container =
-				new ConcurrentMessageListenerContainer<>(cf, topic1);
-		final CountDownLatch latch = new CountDownLatch(4);
-		container.setMessageListener(new MessageListener<Integer, String>() {
-
-			@Override
-			public void onMessage(ConsumerRecord<Integer, String> message) {
-				logger.info("auto: " + message);
-				latch.countDown();
-			}
-		});
-		final CountDownLatch rebalancePartitionsAssignedLatch = new CountDownLatch(2);
-		final CountDownLatch rebalancePartitionsRevokedLatch = new CountDownLatch(2);
-		container.setConsumerRebalanceListener(new ConsumerRebalanceListener() {
-
-			@Override
-			public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
-				logger.info("In test, partitions revoked:" + partitions);
-				rebalancePartitionsRevokedLatch.countDown();
-			}
-
-			@Override
-			public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
-				logger.info("In test, partitions assigned:" + partitions);
-				rebalancePartitionsAssignedLatch.countDown();
-			}
-
-		});
-
-		container.setConcurrency(2);
-		container.setBeanName("testAuto");
-		container.start();
-		ContainerTestUtils.waitForAssignment(container, embeddedKafka.getPartitionsPerTopic());
-		Map<String, Object> senderProps = KafkaTestUtils.producerProps(embeddedKafka);
-		ProducerFactory<Integer, String> pf = new DefaultKafkaProducerFactory<Integer, String>(senderProps);
-		KafkaTemplate<Integer, String> template = new KafkaTemplate<>(pf);
-		template.setDefaultTopic(topic1);
-		template.send(0, "foo");
-		template.send(2, "bar");
-		template.send(0, "baz");
-		template.send(2, "qux");
-		template.flush();
-		assertThat(latch.await(60, TimeUnit.SECONDS)).isTrue();
-		assertThat(rebalancePartitionsAssignedLatch.await(60, TimeUnit.SECONDS)).isTrue();
-		assertThat(rebalancePartitionsRevokedLatch.await(60, TimeUnit.SECONDS)).isTrue();
-		container.stop();
-		logger.info("Stop auto");
-	}
-
 	@Test
 	public void testAfterListenCommit() throws Exception {
 		logger.info("Start manual");