public static boolean acceptEndpoint(String endpointUrl) {
      return endpointUrl != null && endpointUrl.matches(ENDPOINT_PATTERN_STRING);
   }
@Test
   void testAcceptEndpoint() {
      AsyncTestSpecification specification = new AsyncTestSpecification();
      KafkaMessageConsumptionTask task = new KafkaMessageConsumptionTask(specification);

      assertTrue(KafkaMessageConsumptionTask.acceptEndpoint("kafka://localhost/testTopic"));

      assertTrue(KafkaMessageConsumptionTask.acceptEndpoint("kafka://localhost:9092/testTopic"));

      assertTrue(
            KafkaMessageConsumptionTask.acceptEndpoint("kafka://localhost/testTopic?securityProtocol=SASL_PLAINTEXT"));
      ;

      assertTrue(KafkaMessageConsumptionTask
            .acceptEndpoint("kafka://localhost:9094/testTopic?securityProtocol=SASL_PLAINTEXT"));

      assertTrue(KafkaMessageConsumptionTask.acceptEndpoint(
            "kafka://my-cluster-kafka-bootstrap-kafka.apps.cluster-943b.943b.example.com:443/UsersignedupAPI_0.1.2_user-signedup"));
   }