This is an automated email from the ASF dual-hosted git repository. tledkov pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push: new b50d0fbe IGNITE-21261 Fix exception 'Unknown topic' is never thrown in KafkaToIgniteMetadataUpdater (#253) b50d0fbe is described below commit b50d0fbed740461703c284e64ed2bf4686634225 Author: xintrian <38949442+xintr...@users.noreply.github.com> AuthorDate: Tue Jan 16 17:33:50 2024 +0300 IGNITE-21261 Fix exception 'Unknown topic' is never thrown in KafkaToIgniteMetadataUpdater (#253) --- .../java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdater.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 6135b9db..97b5bfed 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 @@ public class KafkaToIgniteMetadataUpdater implements AutoCloseable, OffsetCommit List<PartitionInfo> topicMeta = cnsmr.partitionsFor(metaTopic, Duration.ofMillis(kafkaReqTimeout)); - if (topicMeta == null) + if (F.isEmpty(topicMeta)) throw new IgniteException("Unknown topic: " + metaTopic); parts = topicMeta