famous-quill-82626
02/13/2023, 1:15 AMquery listUsers($input: ListUsersInput!) {
listUsers(input: $input) {
start
count
total
users {
urn
username
isNativeUser
info {
active
displayName
title
firstName
lastName
fullName
email
__typename
}
editableProperties {
displayName
pictureLink
teams
title
skills
__typename
}
status
roles: relationships(
input: {types: ["IsMemberOfRole"], direction: OUTGOING, start: 0}
) {
start
count
total
relationships {
entity {
... on DataHubRole {
urn
type
name
relationships(input: {types: ["IsMemberOfRole"], direction: INCOMING}) {
start
count
total
__typename
}
__typename
}
__typename
}
__typename
}
__typename
}
__typename
}
__typename
}
}
---> result:
{
"data": {
"listUsers": {
"start": 0,
"count": 25,
"total": 0,
"users": [],
"__typename": "ListUsersResult"
}
},
"extensions": {}
}
Is this query attempting to get the User list from the DataHub database?
..or if not, what is it querying?
Could database access be affecting the returned result?
Thanks,
Petegentle-hamburger-31302
02/13/2023, 10:07 AMbig-carpet-38439
02/13/2023, 10:50 PMdatahub-upgrade container will perform a required reindexing which can take some time to complete. During this time, you may not see your entities as expected!famous-quill-82626
02/16/2023, 1:56 AM01:24:12 [ThreadPoolTaskExecutor-1] WARN o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-mce-consumer-job-client-1, groupId=mce-consumer-job-client] Error while fetching metadata with correlation id 2 : {dh_integrate_MetadataChangeEvent_v1=TOPIC_AUTHORIZATION_FAILED}
01:24:12 [ThreadPoolTaskExecutor-1] ERROR org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-mce-consumer-job-client-1, groupId=mce-consumer-job-client] Topic authorization failed for topics [dh_integrate_MetadataChangeEvent_v1]
01:24:12 [ThreadPoolTaskExecutor-1] INFO org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-mce-consumer-job-client-1, groupId=mce-consumer-job-client] Cluster ID: lkc-9kk0zv
01:24:12 [ThreadPoolTaskExecutor-1] ERROR o.s.k.l.KafkaMessageListenerContainer$ListenerConsumer - Authorization Exception and no authorizationExceptionRetryInterval set
org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [dh_integrate_MetadataChangeEvent_v1]
01:24:12 [ThreadPoolTaskExecutor-1] ERROR o.s.k.l.KafkaMessageListenerContainer$ListenerConsumer - Fatal consumer exception; stopping container
01:24:12 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values:
allow.auto.create.topics = true
<http://auto.commit.interval.ms|auto.commit.interval.ms> = 10000
auto.offset.reset = latest
bootstrap.servers = [pkc-3wp5o.ap-southeast-2.aws.confluent.cloud:9092]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id =
client.rack =
<http://connections.max.idle.ms|connections.max.idle.ms> = 540000
<http://default.api.timeout.ms|default.api.timeout.ms> = 60000
enable.auto.commit = true
exclude.internal.topics = true
fetch.max.bytes = 52428800
<http://fetch.max.wait.ms|fetch.max.wait.ms> = 500
fetch.min.bytes = 1
group.id = generic-platform-event-job-client
group.instance.id = null
<http://heartbeat.interval.ms|heartbeat.interval.ms> = 3000
interceptor.classes = []
internal.leave.group.on.close = true
isolation.level = read_uncommitted
key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
max.partition.fetch.bytes = 1048576
<http://max.poll.interval.ms|max.poll.interval.ms> = 300000
max.poll.records = 500
<http://metadata.max.age.ms|metadata.max.age.ms> = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
<http://metrics.sample.window.ms|metrics.sample.window.ms> = 30000
partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
receive.buffer.bytes = 65536
<http://reconnect.backoff.max.ms|reconnect.backoff.max.ms> = 1000
<http://reconnect.backoff.ms|reconnect.backoff.ms> = 50
<http://request.timeout.ms|request.timeout.ms> = 30000
<http://retry.backoff.ms|retry.backoff.ms> = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = PLAIN
security.protocol = SASL_SSL
security.providers = null
send.buffer.bytes = 131072
<http://session.timeout.ms|session.timeout.ms> = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = https
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class io.confluent.kafka.serializers.KafkaAvroDeserializerhallowed-lizard-92381
04/11/2023, 7:44 PMbig-carpet-38439
04/12/2023, 5:30 PMfamous-quill-82626
04/19/2023, 8:44 PM