线程在通过classutils.java加载类时被阻塞
"KafkaConsumer-49" prio=10 tid=0x00007f1178fdd000 nid=0x78e0 waiting for monitor entry [0x00007f1155fb5000]
java.lang.Thread.State: BLOCKED (on object monitor)
at java.lang.ClassLoader.loadClass(ClassLoader.java:403)
- waiting to lock <0x00000006c0655b58> (a java.lang.Object)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
at org.springframework.util.ClassUtils.forName(ClassUtils.java:258)
at org.springframework.data.convert.SimpleTypeInformationMapper.resolveTypeFrom(SimpleTypeInformationMapper.java:56)
at org.springframework.data.convert.DefaultTypeMapper.readType(DefaultTypeMapper.java:103)
at org.springframework.data.convert.DefaultTypeMapper.getDefaultedTypeToBeUsed(DefaultTypeMapper.java:144)
at org.springframework.data.convert.DefaultTypeMapper.readType(DefaultTypeMapper.java:121)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:186)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:176)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:172)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:75)
at org.springframework.data.mongodb.core.MongoTemplate$ReadDbObjectCallback.doWith(MongoTemplate.java:1840)
at org.springframework.data.mongodb.core.MongoTemplate.executeFindMultiInternal(MongoTemplate.java:1536)
at org.springframework.data.mongodb.core.MongoTemplate.doFind(MongoTemplate.java:1336)
at org.springframework.data.mongodb.core.MongoTemplate.doFind(MongoTemplate.java:1322)
at org.springframework.data.mongodb.core.MongoTemplate.find(MongoTemplate.java:495)
at org.springframework.data.mongodb.core.MongoTemplate.find(MongoTemplate.java:486)
at com.snapdeal.coms.timemachine.mao.TimeMachineMao.getVendorProductsForUploadId(TimeMachineMao.java:32)
at com.snapdeal.coms.timemachine.service.TimeMachineService.getVendorProductsForUploadIdAndSupc(TimeMachineService.java:35)
at com.snapdeal.coms.timemachine.event.SupcUploadIdStateUpdateEventHandler.handleEvent(SupcUploadIdStateUpdateEventHandler.java:40)
KafkaConsumer-48" prio=10 tid=0x00007f1178fdb000 nid=0x78df waiting for monitor entry [0x00007f11560b6000]
java.lang.Thread.State: BLOCKED (on object monitor)
at java.lang.ClassLoader.loadClass(ClassLoader.java:403)
- waiting to lock <0x00000006c0655b58> (a java.lang.Object)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
at org.springframework.util.ClassUtils.forName(ClassUtils.java:258)
at org.springframework.data.convert.SimpleTypeInformationMapper.resolveTypeFrom(SimpleTypeInformationMapper.java:56)
at org.springframework.data.convert.DefaultTypeMapper.readType(DefaultTypeMapper.java:103)
at org.springframework.data.convert.DefaultTypeMapper.getDefaultedTypeToBeUsed(DefaultTypeMapper.java:144)
at org.springframework.data.convert.DefaultTypeMapper.readType(DefaultTypeMapper.java:121)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:186)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:176)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:172)
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:75)
at org.springframework.data.mongodb.core.MongoTemplate$ReadDbObjectCallback.doWith(MongoTemplate.java:1840)
at org.springframework.data.mongodb.core.MongoTemplate.executeFindMultiInternal(MongoTemplate.java:1536)
at org.springframework.data.mongodb.core.MongoTemplate.doFind(MongoTemplate.java:1336)
at org.springframework.data.mongodb.core.MongoTemplate.doFind(MongoTemplate.java:1322)
at org.springframework.data.mongodb.core.MongoTemplate.find(MongoTemplate.java:495)
at org.springframework.data.mongodb.core.MongoTemplate.find(MongoTemplate.java:486)
at com.snapdeal.coms.timemachine.mao.TimeMachineMao.getVendorProductsForUploadId(TimeMachineMao.java:32)
at com.snapdeal.coms.timemachine.service.TimeMachineService.getVendorProductsForUploadIdAndSupc(TimeMachineService.java:35)
at com.snapdeal.coms.timemachine.event.SupcUploadIdStateUpdateEventHandler.handleEvent(SupcUploadIdStateUpdateEventHandler.java:40)
at com.snapdeal.coms.timemachine.TimeMachine.onEvent(TimeMachine.java:109)
"KafkaConsumer-46" prio=10 tid=0x00007f1178fd8000 nid=0x78dd waiting for monitor entry [0x00007f11562b8000]
我不确定为什么所有的线程都被阻塞了。我以为类只加载一次，以后就不需要带任何锁了。
共有1个答案
您是否尝试使用consumeroffsetchecker查看消费者是否还活着？您可以在$KAFKA_ROOT_DIR/文件夹中尝试以下命令
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group consumer-group1 --zkconnect zkhost:zkport --topic topic1
以下是从他们的FAQ页面中摘录的一些注释
如果消费者抵消在一段时间后没有移动，那么消费者很可能已经停止了。如果消费者偏移在移动，但消费者滞后（日志末尾与消费者偏移之间的差值）在增加，则消费者比生产者慢。如果使用者速度慢，典型的解决方案是增加使用者中的并行度。这可能需要增加主题的分区数。
-
我在我产品环境中发现了一个问题。 我们在一个mq集群中有6个队列，我们有200个线程的线程池（实际上会更多，因为它会在一个独立的线程池中安排一些特殊任务）来处理来自上游的请求，当处理请求时，我会发布一个消息给rabbitmq Broker。 所以我有200个线程将消息发布到这6个队列。 对于每个队列，我将创建一个AMQP连接，对于每个线程，我有一个Channel的threadlocal，这样每个线
-
我试图使用neo4j中的命令从CSV文件中导入大约500,000行数据。 下面是我正在使用的代码： 期望的行为：第一次出现以另一个艺术家为特征的人会创建关系，并且应该将关系的属性设置为1。对于随后的每一次事件，强度属性将增加1。因此，经常以艺术家B为特色的艺术家A应该具有类似的关系 关系是方向性的，在这种情况下，方向性很重要（A以B为特征不同于B以A为特征）。 在确定问题时，是否有其他有用的信息？
-
本文向大家介绍js加载过程阻塞，解决方法？相关面试题，主要包含被问及js加载过程阻塞，解决方法？时的应答技巧和注意事项，需要的朋友参考一下 参考回答： 指定script标签的async属性。 如果async="async"，脚本相对于页面的其余部分异步地执行（当页面继续进行解析时，脚本将被执行） 如果不使用async 且 defer="defer"：脚本将在页面完成解析时执行
-
我试图用一个自定义对象创建一个新线程，然后从主线程调用这个自定义对象方法。其思想是，主线程可以继续执行其他任务，而自定义对象可以继续在第二个线程中工作： 输出为： 它应该更像这样： 所以主线程被阻塞，直到方法完成。主线程是否在第二个线程中等待完成（作为返回类型为空，我认为情况不会如此）？还是在第一个线程中执行，因此阻塞了它？ 我知道使用下面的代码，我可以在另一个线程中执行，但它每次都会从头开始创建
-
我们有一个由2个节点a和B组成的集群。 如果我们在节点a上阻止线程的执行（我是通过远程连接到我的VM并放置断点来执行的），那么节点B认为节点a被分段（这是预期的行为）。 在执行上述场景后，节点A上的任何缓存查找都会被卡住，我们永远不会从IGniteCache中获得结果。 我已经编写了一个测试应用程序来重现这个问题。复制这个问题并不困难，但我已经尽力在readme.md中提供了指导 如果你仍然不清楚
-
在Java中，线程可以有不同的状态： 新建、可运行、阻止、等待、定时等待、终止 但是，当线程被IO阻塞时，其状态为“RUNNABLE”。我如何判断它是否被IO阻止？