使用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

總結

以上是生活随笔為你收集整理的kettle kafka mysql_kettle使用kafka组件消费数据，保存到资源库无法打开问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。