[rocketmq-connect] branch master updated: Fix - check if topic is null. (#439)

[zhoubo]

This is an automated email from the ASF dual-hosted git repository.

zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new 86c5346f Fix - check if topic is null. (#439)
86c5346f is described below

commit 86c5346f0a50e8d2351b233966a693c1f42b5224
Author: changqing <cloo...@163.com>
AuthorDate: Tue Apr 4 09:37:58 2023 +0800

    Fix - check if topic is null. (#439)
    
    * Fix - check if topic is null.
    
    * Fix - check if topic is null.
    
    * Fix - remove unused import.
    
    ---------
    
    Co-authored-by: zhoubo <877036...@qq.com>
---
 .../main/java/org/apache/rocketmq/connect/file/FileSourceTask.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
 
b/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
index ca164291..592e1e28 100644
--- 
a/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
+++ 
b/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
@@ -39,7 +39,6 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -148,7 +147,9 @@ public class FileSourceTask extends SourceTask {
                             fields.add(field);
                             schema.setFields(fields);
                             ConnectRecord connectRecord = new 
ConnectRecord(offsetKey(fileConfig.getFilename()), offsetValue(streamOffset), 
System.currentTimeMillis(), schema, line);
-                            if 
(StringUtils.isNoneBlank(fileConfig.getTopic())) {
+                            if (fileConfig.getTopic() == null) {
+                                connectRecord.addExtension("topic", "");
+                            } else {
                                 connectRecord.addExtension("topic", 
fileConfig.getTopic());
                             }
                             records.add(connectRecord);