Skip to content

Commit 1135440

Browse files
Restore changes lost duraing merge (#13884)
1 parent 90d09d7 commit 1135440

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/kafka_proxy/actors/kafka_metadata_actor.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,11 +140,11 @@ void TKafkaMetadataActor::ProcessTopics() {
140140
}
141141

142142
TActorId TKafkaMetadataActor::SendTopicRequest(const TMetadataRequestData::TMetadataRequestTopic& topicRequest) {
143-
KAFKA_LOG_D("Describe partitions locations for topic '" << *topicRequest.Name << "' for user '" << Context->UserToken->GetUserSID() << "'");
143+
KAFKA_LOG_D("Describe partitions locations for topic '" << *topicRequest.Name << "' for user '" << GetUsernameOrAnonymous(Context) << "'");
144144

145145
TGetPartitionsLocationRequest locationRequest{};
146146
locationRequest.Topic = NormalizePath(Context->DatabasePath, topicRequest.Name.value());
147-
locationRequest.Token = Context->UserToken->GetSerializedToken();
147+
locationRequest.Token = GetUserSerializedToken(Context);
148148
locationRequest.Database = Context->DatabasePath;
149149

150150
PendingResponses++;

0 commit comments

Comments
 (0)