(ignite-extensions) branch master updated: IGNITE-21261 Fix exception 'Unknown topic' is never thrown in KafkaToIgniteMetadataUpdater (#253)

[tledkov]

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