java.util.concurrent.ExecutionException: java.lang.IllegalStateException: > No kafka producer available. > at com.google.common.util.concurrent.AbstractFuture$ > Sync.getValue(AbstractFuture.java:294) ~[com.google.guava.guava-13.0. > 1.jar:na] > at com.google.common.util.concurrent.AbstractFuture$ > Sync.get(AbstractFuture.java:281) ~[com.google.guava.guava-13.0.1.jar:na] > at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116) > ~[com.google.guava.guava-13.0.1.jar:na] > at co.cask.cdap.data2.audit.KafkaAuditPublisher.publish(KafkaAuditPublisher.java:72) > ~[co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.audit.AuditPublishers.publishAccess(AuditPublishers.java:72) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework. > publishAudit(LineageWriterDatasetFramework.java:211) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework. > writeLineage(LineageWriterDatasetFramework.java:186) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework$ > BasicDatasetAccessRecorder.recordLineage(LineageWriterDatasetFramework.java:263) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.dataset2.DefaultDatasetRuntimeContext.recordAccess( > DefaultDatasetRuntimeContext.java:178) [co.cask.cdap.cdap-data- > fabric-3.5.1.jar:na] > at co.cask.cdap.data2.dataset2.DefaultDatasetRuntimeContext.onMethodEntry( > DefaultDatasetRuntimeContext.java:166) [co.cask.cdap.cdap-data- > fabric-3.5.1.jar:na] > at co.cask.cdap.api.dataset.lib.KeyValueTable.read(KeyValueTable.java) > [na:na] > at co.cask.cdap.examples.helloworld.LogHelloWorld$ > LogGreetingHandler.greet(LogHelloWorld.java:187) [unpacked/:na] > at co.cask.cdap.examples.helloworld.LogHelloWorld$ > LogGreetingHandlerb532e958911516c047bef3bd21bcdf4e.greet(Unknown Source) > [na:na] > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > ~[na:1.8.0_102] > at sun.reflect.NativeMethodAccessorImpl.invoke( > NativeMethodAccessorImpl.java:62) ~[na:1.8.0_102] > at sun.reflect.DelegatingMethodAccessorImpl.invoke( > DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_102] > at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_102] > at co.cask.http.HttpMethodInfo.invoke(HttpMethodInfo.java:80) > [co.cask.http.netty-http-0.15.0.jar:na] > at co.cask.http.HttpDispatcher.messageReceived(HttpDispatcher.java:38) > [co.cask.http.netty-http-0.15.0.jar:na] > at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream( > SimpleChannelUpstreamHandler.java:70) [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream( > DefaultChannelPipeline.java:564) [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.channel.DefaultChannelPipeline$ > DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) > [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.handler.execution.ChannelUpstreamEventRunnable.doRun( > ChannelUpstreamEventRunnable.java:43) [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.handler.execution.ChannelEventRunnable.run(ChannelEventRunnable.java:67) > [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolEx > ecutor$ChildExecutor.run(OrderedMemoryAwareThreadPoolExecutor.java:314) > [io.netty.netty-3.6.6.Final.jar:na] > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Samebug tips

Do you know how to solve this issue? Write a tip to help other users and build your expert profile.

Solutions on the web

via Google Groups by chuncheng, 1 year ago
java.lang.IllegalStateException: > No kafka producer available. > at com.google.common.util.concurrent.AbstractFuture$ > Sync.getValue(AbstractFuture.java:294) ~[com.google.guava.guava-13.0. > 1.jar:na] > at
java.util.concurrent.ExecutionException: java.lang.IllegalStateException: > No kafka producer available. > at com.google.common.util.concurrent.AbstractFuture$ > Sync.getValue(AbstractFuture.java:294) ~[com.google.guava.guava-13.0. > 1.jar:na] > at com.google.common.util.concurrent.AbstractFuture$ > Sync.get(AbstractFuture.java:281) ~[com.google.guava.guava-13.0.1.jar:na] > at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116) > ~[com.google.guava.guava-13.0.1.jar:na] > at co.cask.cdap.data2.audit.KafkaAuditPublisher.publish(KafkaAuditPublisher.java:72) > ~[co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.audit.AuditPublishers.publishAccess(AuditPublishers.java:72) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework. > publishAudit(LineageWriterDatasetFramework.java:211) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework. > writeLineage(LineageWriterDatasetFramework.java:186) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.metadata.writer.LineageWriterDatasetFramework$ > BasicDatasetAccessRecorder.recordLineage(LineageWriterDatasetFramework.java:263) > [co.cask.cdap.cdap-data-fabric-3.5.1.jar:na] > at co.cask.cdap.data2.dataset2.DefaultDatasetRuntimeContext.recordAccess( > DefaultDatasetRuntimeContext.java:178) [co.cask.cdap.cdap-data- > fabric-3.5.1.jar:na] > at co.cask.cdap.data2.dataset2.DefaultDatasetRuntimeContext.onMethodEntry( > DefaultDatasetRuntimeContext.java:166) [co.cask.cdap.cdap-data- > fabric-3.5.1.jar:na] > at co.cask.cdap.api.dataset.lib.KeyValueTable.read(KeyValueTable.java) > [na:na] > at co.cask.cdap.examples.helloworld.LogHelloWorld$ > LogGreetingHandler.greet(LogHelloWorld.java:187) [unpacked/:na] > at co.cask.cdap.examples.helloworld.LogHelloWorld$ > LogGreetingHandlerb532e958911516c047bef3bd21bcdf4e.greet(Unknown Source) > [na:na] > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > ~[na:1.8.0_102] > at sun.reflect.NativeMethodAccessorImpl.invoke( > NativeMethodAccessorImpl.java:62) ~[na:1.8.0_102] > at sun.reflect.DelegatingMethodAccessorImpl.invoke( > DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_102] > at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_102] > at co.cask.http.HttpMethodInfo.invoke(HttpMethodInfo.java:80) > [co.cask.http.netty-http-0.15.0.jar:na] > at co.cask.http.HttpDispatcher.messageReceived(HttpDispatcher.java:38) > [co.cask.http.netty-http-0.15.0.jar:na] > at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream( > SimpleChannelUpstreamHandler.java:70) [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream( > DefaultChannelPipeline.java:564) [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.channel.DefaultChannelPipeline$ > DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) > [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.handler.execution.ChannelUpstreamEventRunnable.doRun( > ChannelUpstreamEventRunnable.java:43) [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.handler.execution.ChannelEventRunnable.run(ChannelEventRunnable.java:67) > [io.netty.netty-3.6.6.Final.jar:na] > at org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolEx > ecutor$ChildExecutor.run(OrderedMemoryAwareThreadPoolExecutor.java:314) > [io.netty.netty-3.6.6.Final.jar:na] > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

Users with the same issue

You are the first who have seen this exception. Write a tip to help other users and build your expert profile.

Write tip

Know the solutions? Share your knowledge to help other developers to debug faster.