a lot of warning blocking message

[naruto]

Hi All

I am new to Quasar and trying to implement my first application by it.

My application is consume message from apache kafka and I reference the sample here:

https://github.com/circlespainter/quasar-actors-integration-examples/blob/master/src/main/java/co/paralleluniverse/actors/integration/examples/direct/kafka/Main.java

But, I don't use the FiberKafkaProducer (I use the kafka client's KafkaProducer directly).

Although the message can be publish and consume normally in my test run.

But, a lot of fiber is block message appear in the console like below:

WARNING: fiber Fiber@10000001:producer[task: ParkableForkJoinTask@585bf21(Fiber@10000001), target: co.paralleluniverse.actors.ActorRunner@1868b960, scheduler: co.paralleluniverse.fibers.FiberForkJoinScheduler@ceb1303] is blocking a thread (Thread[ForkJoinPool-default-fiber-pool-worker-5,5,main]).

at sun.security.provider.SecureRandom.engineNextBytes(Unknown Source)

at java.security.SecureRandom.nextBytes(Unknown Source)

at sun.nio.ch.PipeImpl$Initializer$LoopbackConnector.run(Unknown Source)

at sun.nio.ch.PipeImpl$Initializer.run(Unknown Source)

at sun.nio.ch.PipeImpl$Initializer.run(Unknown Source)

at java.security.AccessController.doPrivileged(Native Method)

at sun.nio.ch.PipeImpl.<init>(Unknown Source)

at sun.nio.ch.SelectorProviderImpl.openPipe(Unknown Source)

at java.nio.channels.Pipe.open(Unknown Source)

at sun.nio.ch.WindowsSelectorImpl.<init>(Unknown Source)

at sun.nio.ch.WindowsSelectorProvider.openSelector(Unknown Source)

at java.nio.channels.Selector.open(Unknown Source)

at org.apache.kafka.common.network.Selector.<init>(Selector.java:123)

at org.apache.kafka.common.network.Selector.<init>(Selector.java:147)

at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:306)

at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:191)

at com.lifevo.qtest.App$ProducerActor.doRun(App.java:61)

at com.lifevo.qtest.App$ProducerActor.doRun(App.java:1)

at co.paralleluniverse.actors.Actor.run0(Actor.java:710)

at co.paralleluniverse.actors.ActorRunner.run(ActorRunner.java:51)

at co.paralleluniverse.fibers.Fiber.run(Fiber.java:1097)

Is it normal ?? Or I miss something in my code ??

Can I skip these warning or disable it ??

The attachment is my code.

Please kindly give me some suggestion about it, thanks.

Cheers~~