bframke commented on issue #743: Kafka Component Writing Messages with ProducerTemplate URL: https://github.com/apache/camel-quarkus/issues/743#issuecomment-591278443 Tried it out and got stuck. From VisualVM I have this information regarding how it gets stuck. The State is RUNNABLE but you can see that nothing is happening on it. ``` java.lang.Thread.State: RUNNABLE at java.io.FileOutputStream.writeBytes(Native Method) at java.io.FileOutputStream.write(FileOutputStream.java:326) at java.io.BufferedOutputStream.write(BufferedOutputStream.java:122) - locked <0x000000064bc3b1a8> (a java.io.BufferedOutputStream) at java.io.PrintStream.write(PrintStream.java:480) - locked <0x000000064bc3b188> (a java.io.PrintStream) at org.jboss.logmanager.handlers.UncloseableOutputStream.write(UncloseableOutputStream.java:41) at org.jboss.logmanager.handlers.UncloseableOutputStream.write(UncloseableOutputStream.java:41) at org.jboss.logmanager.handlers.UninterruptibleOutputStream.write(UninterruptibleOutputStream.java:81) at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:221) at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:291) at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:295) at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:141) - locked <0x000000064bca1d20> (a java.io.OutputStreamWriter) at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:229) at java.io.BufferedWriter.flush(BufferedWriter.java:254) - locked <0x000000064bca1d20> (a java.io.OutputStreamWriter) at org.jboss.logmanager.handlers.WriterHandler.safeFlush(WriterHandler.java:165) at org.jboss.logmanager.handlers.WriterHandler.flush(WriterHandler.java:135) - locked <0x000000064bca1ce8> (a java.lang.Object) at org.jboss.logmanager.ExtHandler.doPublish(ExtHandler.java:94) at org.jboss.logmanager.handlers.WriterHandler.doPublish(WriterHandler.java:64) - locked <0x000000064bca1ce8> (a java.lang.Object) at org.jboss.logmanager.ExtHandler.publish(ExtHandler.java:66) at org.jboss.logmanager.handlers.DelayedHandler.publishToChildren(DelayedHandler.java:208) at org.jboss.logmanager.handlers.DelayedHandler.doPublish(DelayedHandler.java:49) at org.jboss.logmanager.ExtHandler.publish(ExtHandler.java:66) at org.jboss.logmanager.LoggerNode.publish(LoggerNode.java:316) at org.jboss.logmanager.LoggerNode.publish(LoggerNode.java:324) at org.jboss.logmanager.LoggerNode.publish(LoggerNode.java:324) at org.jboss.logmanager.LoggerNode.publish(LoggerNode.java:324) at org.jboss.logmanager.LoggerNode.publish(LoggerNode.java:324) at org.jboss.logmanager.Logger.logRaw(Logger.java:748) at org.jboss.logmanager.Logger.log(Logger.java:706) at org.jboss.logging.JBossLogManagerLogger.doLogf(JBossLogManagerLogger.java:53) at org.jboss.logging.Logger.infof(Logger.java:1136) at de.telekom.camel.ProducerContextListener$1.lambda$configure$0(ProducerContextListener.java:74) at de.telekom.camel.ProducerContextListener$1$$Lambda$513/322112198.process(Unknown Source) at org.apache.camel.support.processor.DelegateSyncProcessor.process(DelegateSyncProcessor.java:64) at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$RedeliveryState.run(RedeliveryErrorHandler.java:476) at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:185) at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:59) at org.apache.camel.processor.Pipeline.process(Pipeline.java:87) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:228) at org.apache.camel.component.netty.handlers.ServerChannelHandler.processAsynchronously(ServerChannelHandler.java:141) at org.apache.camel.component.netty.handlers.ServerChannelHandler.channelRead0(ServerChannelHandler.java:112) at org.apache.camel.component.netty.http.handlers.HttpServerChannelHandler.channelRead0(HttpServerChannelHandler.java:219) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at org.apache.camel.component.netty.http.handlers.HttpServerMultiplexChannelHandler.channelRead0(HttpServerMultiplexChannelHandler.java:156) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) at io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:56) at io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:365) at io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:66) at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at java.lang.Thread.run(Thread.java:748) ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
