@@ -771,9 +771,9 @@ class DynamicBrokerConfigTest {
771771 }
772772
773773 @ Test
774- def testDynamicRemoteCopyLagThrowsOnIncorrectConfig (): Unit = {
775- // remote copy lag ms cannot exceed effective local retention ms
776- verifyIncorrectRemoteCopyLagProps (
774+ def testDynamicLogRemoteCopyLagThrowsOnIncorrectConfig (): Unit = {
775+ // log remote copy lag ms cannot exceed effective log local retention ms
776+ verifyIncorrectLogRemoteCopyLagProps (
777777 retentionMs = 1000L ,
778778 logLocalRetentionMs = - 2L ,
779779 logRemoteCopyLagMs = 1001L ,
@@ -782,8 +782,8 @@ class DynamicBrokerConfigTest {
782782 logRemoteCopyLagBytes = 100L
783783 )
784784
785- // remote copy lag bytes cannot exceed effective local retention bytes
786- verifyIncorrectRemoteCopyLagProps (
785+ // log remote copy lag bytes cannot exceed effective log local retention bytes
786+ verifyIncorrectLogRemoteCopyLagProps (
787787 retentionMs = 1000L ,
788788 logLocalRetentionMs = - 2L ,
789789 logRemoteCopyLagMs = 100L ,
@@ -794,12 +794,12 @@ class DynamicBrokerConfigTest {
794794
795795 }
796796
797- def verifyIncorrectRemoteCopyLagProps (retentionMs : Long ,
798- logLocalRetentionMs : Long ,
799- logRemoteCopyLagMs : Long ,
800- retentionBytes : Long ,
801- logLocalRetentionBytes : Long ,
802- logRemoteCopyLagBytes : Long ): Unit = {
797+ def verifyIncorrectLogRemoteCopyLagProps (retentionMs : Long ,
798+ logLocalRetentionMs : Long ,
799+ logRemoteCopyLagMs : Long ,
800+ retentionBytes : Long ,
801+ logLocalRetentionBytes : Long ,
802+ logRemoteCopyLagBytes : Long ): Unit = {
803803 val props = TestUtils .createBrokerConfig(0 , port = 8181 )
804804 props.put(ServerLogConfigs .LOG_RETENTION_TIME_MILLIS_CONFIG , retentionMs.toString)
805805 props.put(ServerLogConfigs .LOG_RETENTION_BYTES_CONFIG , retentionBytes.toString)
0 commit comments