You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2020/02/02 18:33:00 UTC

[jira] [Created] (KAFKA-9496) Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

Matthias J. Sax created KAFKA-9496:
--------------------------------------

             Summary: Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads
                 Key: KAFKA-9496
                 URL: https://issues.apache.org/jira/browse/KAFKA-9496
             Project: Kafka
          Issue Type: Bug
          Components: admin, core, unit tests
    Affects Versions: 2.5.0
            Reporter: Matthias J. Sax


[https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/450/testReport/junit/kafka.api/SslAdminIntegrationTest/testSynchronousAuthorizerAclUpdatesBlockRequestThreads/]
{quote}org.apache.kafka.common.errors.DisconnectException: Cancelled createAcls request with correlation id 3 due to node 0 being disconnected{quote}
There was no other error and no real StackTrace.

STDERR:
{quote}[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=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},\{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.{quote}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)