-
Notifications
You must be signed in to change notification settings - Fork 142
Multi tenant configuration - fix handling of group management topics tenant #849
Multi tenant configuration - fix handling of group management topics tenant #849
Conversation
Demogorgon314
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Overall LGTM. Just left few comment. PTAL.
...rc/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManager.java
Outdated
Show resolved
Hide resolved
...rc/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManager.java
Outdated
Show resolved
Hide resolved
...rc/main/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManager.java
Outdated
Show resolved
Hide resolved
| @@ -1154,6 +1158,7 @@ public void removeGroupsForPartition(int offsetsPartition, | |||
| TopicPartition topicPartition = new TopicPartition( | |||
| GROUP_METADATA_TOPIC_NAME, offsetsPartition | |||
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I guess this topic name need change too, it will make log more accurate.
| @Default | ||
| private String offsetsTopicName = DefaultOffsetsTopicName; | ||
|
|
||
| public String getCurrentOffsetsTopicName(String tenant) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
IMO, We can replace placeholder when OffsetConfig object creating, Instead of replacing placeholder every time we get it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it makes sense to me.
But I have to perform some refactors.
I will update the patch in the next days
|
After rebasing to current master this patch is useless. |
OffsetConfig was still using "public" as tenant
Changes: