-
Notifications
You must be signed in to change notification settings - Fork 14.4k
MINOR: Follow up KAFKA-19080 MetadataLogConfig #19842
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
MINOR: Follow up KAFKA-19080 MetadataLogConfig #19842
Conversation
A label of 'needs-attention' was automatically added to this PR in order to raise the |
@@ -637,6 +637,12 @@ object KafkaMetadataLog extends Logging { | |||
nodeId | |||
) | |||
|
|||
// Print a warning if users have overridden the internal config | |||
if (config.internalSegmentBytes() != null) { | |||
metadataLog.error(s"Overriding ${MetadataLogConfig.INTERNAL_METADATA_LOG_SEGMENT_BYTES_CONFIG} is only supported for testing. Setting " + |
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.
we should print the warnings only if the segment size is configured to small value. please consider comparing the value to METADATA_LOG_SEGMENT_BYTES_DEFAULT
@@ -637,6 +637,11 @@ object KafkaMetadataLog extends Logging { | |||
nodeId | |||
) | |||
|
|||
if (defaultLogConfig.segmentSize() < config.logSegmentBytes()) { | |||
metadataLog.error(s"Overriding ${MetadataLogConfig.METADATA_LOG_SEGMENT_BYTES_CONFIG} is only supported for testing. Setting " + |
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 should be INTERNAL_METADATA_LOG_SEGMENT_BYTES_CONFIG
See Discussion:
#19371 (comment)
Do the following changes:
INTERNAL_METADATA_LOG_SEGMENT_BYTES_CONFIG
Reviewers: Chia-Ping Tsai chia7712@gmail.com