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)

Reply via email to