Appian Consume from Kafka

Hello everyone,

Just want to know if anyone have experience or have successfully Consume message from Kafka,

I am trying to use the Plug-in "Consume from Kafka", however, the documentation is not have much information. 

Especially not sure what should put for "Data Source Name" and "Transaction Table Name".

For "Data Source Name":

        -  I have create a dummy table along with data type & data store & Record Type, since the type is text, I have tried put the table name, data store name, even recordtype, non of them working

For "Transaction Table Name":

        -  Since it default linked to "tm_job_transaction", I tried leave there also tried use the table I created, nether of them work.

When I run the PM, it do give me success, however nothing received, no message, no table got updated.

Here are the log which mentioned some error:

2024-01-24 14:31:37,470 [Thread-2016] ERROR com.appiancorp.cs.plugin.kafka.consumer.AppianKafkaConsumerThread - Received an exception from consumer: 1139787 - null
java.lang.reflect.UndeclaredThrowableException
	at com.sun.proxy.$Proxy1154.lookup(Unknown Source)
	at com.appiancorp.cs.plugin.kafka.consumer.AppianKafkaConsumer.getConnection(AppianKafkaConsumer.java:182)
	at com.appiancorp.cs.plugin.kafka.consumer.AppianKafkaConsumer.run(AppianKafkaConsumer.java:71)
	at com.appiancorp.cs.plugin.kafka.consumer.AppianKafkaConsumerThread.run(AppianKafkaConsumerThread.java:30)
Caused by: java.lang.reflect.InvocationTargetException
	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 com.appiancorp.common.ContextClassLoaderSwitchingInvocationHandler$1.call(ContextClassLoaderSwitchingInvocationHandler.java:27)
	at com.appiancorp.common.ContextClassLoaderSwitcher.runInContext(ContextClassLoaderSwitcher.java:28)
	at com.appiancorp.common.ContextClassLoaderSwitchingInvocationHandler.invoke(ContextClassLoaderSwitchingInvocationHandler.java:23)
	... 4 more
Caused by: javax.naming.NameNotFoundException: Name [GSKAFKA_TEST] is not bound in this Context. Unable to find [GSKAFKA_TEST].
	at org.apache.naming.NamingContext.lookup(NamingContext.java:840)
	at org.apache.naming.NamingContext.lookup(NamingContext.java:158)
	at org.apache.naming.NamingContext.lookup(NamingContext.java:850)
	at org.apache.naming.NamingContext.lookup(NamingContext.java:158)
	at org.apache.naming.NamingContext.lookup(NamingContext.java:850)
	at org.apache.naming.NamingContext.lookup(NamingContext.java:172)
	at org.apache.naming.SelectorContext.lookup(SelectorContext.java:161)
	at javax.naming.InitialContext.lookup(InitialContext.java:417)
	at com.appiancorp.tomcat.naming.TomcatInitialContextFactory$InitialContextNamingAdapter.lambda$lookup$19(TomcatInitialContextFactory.java:186)
	at com.appiancorp.tomcat.naming.TomcatInitialContextFactory.runInWebAppContext(TomcatInitialContextFactory.java:39)
	at com.appiancorp.tomcat.naming.TomcatInitialContextFactory.access$000(TomcatInitialContextFactory.java:19)
	at com.appiancorp.tomcat.naming.TomcatInitialContextFactory$InitialContextNamingAdapter.lookup(TomcatInitialContextFactory.java:186)
	at javax.naming.InitialContext.lookup(InitialContext.java:417)
	at com.appiancorp.common.StrictNamingInitialContext.lookup(StrictNamingInitialContext.java:121)
	... 11 more

Couple questions:

-  How to set-up "Data Source Name" and "Transaction Table Name"?

-  What should I received via the plug-in? Or some extra steps are necessary?

If anyone successfully consume from Kafka, please please help!

Thank you in advance,

Kind regards