update exception messages for TopicConfigurationMismatch (#370)

Author: tim-quix

quixstreams/models/topics/manager.py

@@ -446,15 +446,17 @@ def validate_all_topics(self, timeout: Optional[float] = None):
 
                 if changelog_cfg.num_partitions != source_cfg.num_partitions:
                     raise TopicConfigurationMismatch(
-                        f'Invalid partition count for the topic "{source_name}": '
+                        f'changelog topic "{changelog.name}" partition count '
+                        f'does not match its source topic "{source_name}": '
                         f"expected {source_cfg.num_partitions}, "
-                        f"got {changelog_cfg.num_partitions}"
+                        f'got {changelog_cfg.num_partitions}"'
                     )
                 if changelog_cfg.replication_factor != source_cfg.replication_factor:
                     raise TopicConfigurationMismatch(
-                        f'Invalid replication factor for the topic "{source_name}": '
+                        f'changelog topic "{changelog.name}" replication factor '
+                        f'does not match its source topic "{source_name}": '
                         f"expected {source_cfg.replication_factor}, "
-                        f"got {changelog_cfg.num_partitions}"
+                        f'got {changelog_cfg.replication_factor}"'
                     )
 
         logger.info(f"Kafka topics validation complete")

tests/test_quixstreams/test_models/test_topics/test_manager.py

@@ -249,7 +249,7 @@ def test_validate_all_topics_changelog_partition_count_mismatch(
             ),
         }
 
-        with pytest.raises(TopicConfigurationMismatch, match="Invalid partition count"):
+        with pytest.raises(TopicConfigurationMismatch, match="partition count"):
             topic_manager.validate_all_topics()
 
     def test_validate_all_topics_changelog_replication_factor_mismatch(
@@ -281,9 +281,7 @@ def test_validate_all_topics_changelog_replication_factor_mismatch(
             ),
         }
 
-        with pytest.raises(
-            TopicConfigurationMismatch, match="Invalid replication factor"
-        ):
+        with pytest.raises(TopicConfigurationMismatch, match="replication factor"):
             topic_manager.validate_all_topics()
 
     def test_topic_name_len_exceeded(self, topic_manager_factory):