WARNING poll timeout issue

Author: brandboat

clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/security/GroupAuthorizerIntegrationTest.java

@@ -329,7 +329,7 @@ private void testConsumeUnsubscribeWithOrWithoutGroupPermission(ClusterInstance
             producer.send(new ProducerRecord<>(topic, "message".getBytes())).get();
             consumer.subscribe(Collections.singletonList(topic));
             TestUtils.waitForCondition(() -> {
-                ConsumerRecords<byte[], byte[]> records = consumer.poll(Duration.ofSeconds(15));
+                ConsumerRecords<byte[], byte[]> records = consumer.poll(Duration.ofMillis(100));
                 return records.count() == 1;
             }, "consumer failed to receive message");
             if (!withGroupPermission) {
@@ -385,7 +385,7 @@ private void testConsumeCloseWithGroupPermission(ClusterInstance clusterInstance
             producer.send(new ProducerRecord<>(topic, "message".getBytes())).get();
             consumer.subscribe(List.of(topic));
             TestUtils.waitForCondition(() -> {
-                ConsumerRecords<byte[], byte[]> records = consumer.poll(Duration.ofSeconds(15));
+                ConsumerRecords<byte[], byte[]> records = consumer.poll(Duration.ofMillis(100));
                 return records.count() == 1;
             }, "consumer failed to receive message");
         } finally {
@@ -435,7 +435,7 @@ private void testAuthorizedProduceAndConsume(ClusterInstance clusterInstance, Gr
             TopicPartition topicPartition = new TopicPartition(topic, 0);
             consumer.assign(List.of(topicPartition));
             TestUtils.waitForCondition(() -> {
-                ConsumerRecords<byte[], byte[]> records = consumer.poll(Duration.ofSeconds(15));
+                ConsumerRecords<byte[], byte[]> records = consumer.poll(Duration.ofMillis(100));
                 return records.count() == 1;
             }, "consumer failed to receive message");
         }