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
Discussion posts and replies are publicly visible
SPAMMER