| commit | b50d0fbed740461703c284e64ed2bf4686634225 | [log] [tgz] |
|---|---|---|
| author | xintrian <38949442+xintrian@users.noreply.github.com> | Tue Jan 16 17:33:50 2024 +0300 |
| committer | GitHub <noreply@github.com> | Tue Jan 16 17:33:50 2024 +0300 |
| tree | 9712c07285b25cbdb3ef47fe79d081a4be01648a | |
| parent | 9c6344145d199c3b7f1294f5bbefdf3ef60ee40a [diff] |
IGNITE-21261 Fix exception 'Unknown topic' is never thrown in KafkaToIgniteMetadataUpdater (#253)
diff --git a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java index 6135b9d..97b5bfe 100644 --- a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java +++ b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java
@@ -107,7 +107,7 @@ List<PartitionInfo> topicMeta = cnsmr.partitionsFor(metaTopic, Duration.ofMillis(kafkaReqTimeout)); - if (topicMeta == null) + if (F.isEmpty(topicMeta)) throw new IgniteException("Unknown topic: " + metaTopic); parts = topicMeta