[KAFKA-9496] Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 2.5.0
• Component/s: admin, core, unit tests
• Labels: flaky-test
• Assignee: Unassigned
• Reporter: Matthias J. Sax
• Created: 02/Feb/20 18:32
• Updated: 02/Feb/20 18:32

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.