Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9496

Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Critical
    • Resolution: Unresolved
    • Affects Version/s: 2.5.0
    • Fix Version/s: None
    • Component/s: admin, core, unit tests
    • Labels:

      Description

      https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/450/testReport/junit/kafka.api/SslAdminIntegrationTest/testSynchronousAuthorizerAclUpdatesBlockRequestThreads/

      org.apache.kafka.common.errors.DisconnectException: Cancelled createAcls request with correlation id 3 due to node 0 being disconnected

      There was no other error and no real StackTrace.

      STDERR:

      [2020-02-01 20:16:40,135] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition mytopic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:16:40,136] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition mytopic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-02-01 20:16:52,587] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=4, api=CREATE_ACLS, version=1, body={creations=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,590] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=5, api=DELETE_ACLS, version=1, body={filters=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,696] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=7, api=DESCRIBE_ACLS, version=2, body={resource_type=2,resource_name_filter=,resource_pattern_type=3,principal_filter=User:,host_filter=,operation=2,permission_type=3,_tagged_fields={}} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,698] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=8, api=CREATE_ACLS, version=1, body={creations=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,700] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=9, api=DELETE_ACLS, version=1, body={filters=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,730] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=17, api=DESCRIBE_ACLS, version=2, body={resource_type=2,resource_name_filter=,resource_pattern_type=3,principal_filter=User:,host_filter=,operation=2,permission_type=3,_tagged_fields={}} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,731] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=18, api=CREATE_ACLS, version=1, body={creations=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,732] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=19, api=DELETE_ACLS, version=1, body={filters=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,736] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=21, api=CREATE_ACLS, version=1, body={creations=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized. [2020-02-01 20:16:52,738] ERROR [KafkaApi-1] Error when handling request: clientId=adminclient-309, correlationId=22, api=DELETE_ACLS, version=1, body={filters=[

      Unknown macro: {resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User}

      ,{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76) org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=2, connectionId=127.0.0.1:36907-127.0.0.1:60258-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mjsax Matthias J. Sax
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: