Skip to content

Commit 038e5f9

Browse files
committed
fix(tests): update exception type in ControllerConfigurationValidatorTableTest for schema validation
1 parent e127eaa commit 038e5f9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: core/src/test/scala/unit/kafka/server/ControllerConfigurationValidatorTableTest.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import kafka.utils.TestUtils
1515
import org.apache.kafka.common.config.ConfigResource
1616
import org.apache.kafka.common.config.ConfigResource.Type.TOPIC
1717
import org.apache.kafka.common.config.TopicConfig.TABLE_TOPIC_SCHEMA_TYPE_CONFIG
18-
import org.apache.kafka.common.errors.InvalidRequestException
18+
import org.apache.kafka.common.errors.InvalidConfigurationException
1919
import org.apache.kafka.server.record.TableTopicSchemaType
2020
import org.junit.jupiter.api.Assertions.{assertEquals, assertThrows}
2121
import org.junit.jupiter.api.{Tag, Test}
@@ -33,7 +33,7 @@ class ControllerConfigurationValidatorTableTest {
3333
config.put(TABLE_TOPIC_SCHEMA_TYPE_CONFIG, TableTopicSchemaType.SCHEMA.name)
3434

3535
// Test without schema registry URL configured
36-
val exception = assertThrows(classOf[InvalidRequestException], () => {
36+
val exception = assertThrows(classOf[InvalidConfigurationException], () => {
3737
validator.validate(new ConfigResource(TOPIC, "foo"), config)
3838
})
3939
assertEquals("Table topic schema type is set to SCHEMA but schema registry URL is not configured", exception.getMessage)

0 commit comments

Comments
 (0)