使用kafka消费者组件消费kafka数据时，填写好相关参数配置

在保存的数据库资源库后无法打开如下图：

出现了如下的错误：

java.lang.IllegalArgumentException: Argument cannot be null

at org.eclipse.swt.SWT.error(Unknown Source)

at org.eclipse.swt.SWT.error(Unknown Source)

at org.eclipse.swt.SWT.error(Unknown Source)

at org.eclipse.swt.widgets.Widget.error(Unknown Source)

at org.eclipse.swt.widgets.TableItem.setText(Unknown Source)

at org.pentaho.big.data.kettle.plugins.kafka.KafkaConsumerInputDialog.populateOptionsData(KafkaConsumerInputDialog.java:502)

at org.pentaho.big.data.kettle.plugins.kafka.KafkaConsumerInputDialog.buildOptionsTable(KafkaConsumerInputDialog.java:422)

at org.pentaho.big.data.kettle.plugins.kafka.KafkaConsumerInputDialog.buildOptionsTab(KafkaConsumerInputDialog.java:338)

at org.pentaho.big.data.kettle.plugins.kafka.KafkaConsumerInputDialog.createAdditionalTabs(KafkaConsumerInputDialog.java:113)

at org.pentaho.di.ui.trans.step.BaseStreamingDialog.open(BaseStreamingDialog.java:251)

at org.pentaho.di.ui.spoon.delegates.SpoonStepsDelegate.editStep(SpoonStepsDelegate.java:120)

at org.pentaho.di.ui.spoon.Spoon.editStep(Spoon.java:8814)

at org.pentaho.di.ui.spoon.trans.TransGraph.editStep(TransGraph.java:3287)

at org.pentaho.di.ui.spoon.trans.TransGraph.mouseDoubleClick(TransGraph.java:785)

at org.eclipse.swt.widgets.TypedListener.handleEvent(Unknown Source)

at org.eclipse.swt.widgets.EventTable.sendEvent(Unknown Source)

at org.eclipse.swt.widgets.Display.sendEvent(Unknown Source)

at org.eclipse.swt.widgets.Widget.sendEvent(Unknown Source)

at org.eclipse.swt.widgets.Display.runDeferredEvents(Unknown Source)

at org.eclipse.swt.widgets.Display.readAndDispatch(Unknown Source)

at org.pentaho.di.ui.spoon.Spoon.readAndDispatch(Spoon.java:1384)

at org.pentaho.di.ui.spoon.Spoon.waitForDispose(Spoon.java:7949)

at org.pentaho.di.ui.spoon.Spoon.start(Spoon.java:9331)

at org.pentaho.di.ui.spoon.Spoon.main(Spoon.java:710)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.pentaho.commons.launcher.Launcher.main(Launcher.java:92)

经常分析源码发现原来是某些参数为空，但是kafka组件未做非空判断，找到组件源码，添加相关非空判断就可以了

修改源码后，重新编译替换原有的的包，这里以kettle的8.2.0.0-342 版本为例：data-integration\system\karaf\system\pentaho\pentaho-big-data-kettle-plugins-kafka\8.2.0.0-342\pentaho-big-data-kettle-plugins-kafka-8.2.0.0-342.jar。替换该目录该jar包即可，其他版本也可以这样修改。

提供一个自己修改好的版本jar: 链接：https://pan.baidu.com/s/1oi3EEidGXPoW32GXQKs9Lw

提取码：zrp0