Skip to content

Commit 4890bc2

Browse files
committed
Fix logger prefix for partition session log events
1 parent 4ece287 commit 4890bc2

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

topic/src/main/java/tech/ydb/topic/read/impl/PartitionSessionImpl.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ public long getId() {
8383
return id;
8484
}
8585

86-
public long getFullId() {
87-
return id;
86+
public String getFullId() {
87+
return fullId;
8888
}
8989

9090
public long getPartitionId() {

topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java

+1
Original file line numberDiff line numberDiff line change
@@ -402,6 +402,7 @@ private void onStartPartitionSessionRequest(YdbTopic.StreamReadMessage.StartPart
402402
.setId(partitionSessionId)
403403
.setFullId(partitionSessionFullId)
404404
.setTopicPath(request.getPartitionSession().getPath())
405+
.setConsumerName(consumerName)
405406
.setPartitionId(partitionId)
406407
.setCommittedOffset(request.getCommittedOffset())
407408
.setPartitionOffsets(new OffsetsRangeImpl(request.getPartitionOffsets().getStart(),

0 commit comments

Comments
 (0)