admin 管理员组文章数量: 1086019
I have deployed the spring boot application with 6 k8 pods for first time not faced any issue. but once redeployed it giving below error. 500 concurrent requests. out of those 23 requests failed.
Generic event exception: Error creating event class: Cannot inject already loaded type: class com.kafka.events.DynamicSampleEvent
on local i tried stress test with 500 sequential request but it have not failed.
added caching layer as well
eventClassCache = new LinkedHashMap<>(100, 0.75f, true) {
protected boolean removeEldestEntry(Map.Entry<String, Class<? extends KafkaPublishEvent<Object>>> eldest) {
return size() > 100;
}
};
private Class<? extends KafkaPublishEvent<Object>> generateEventClass(String eventType) {
String sanitizedEventType = eventType.replaceAll("[^a-zA-Z0-9_.]", "");
try (DynamicType.Unloaded<KafkaPublishEvent> unloadedType = new ByteBuddy()
.subclass(KafkaPublishEvent.class)
.name("com.kafka.events.Dynamic" + sanitizedEventType + "Event")
.make()) {
return (Class<? extends KafkaPublishEvent<Object>>) unloadedType
.load(getClass().getClassLoader(), ClassLoadingStrategy.Default.INJECTION)
.getLoaded();
} catch (Exception e) {
throw new EventGenerationException(ERR_0033, "Error creating event class: " + e.getMessage());
}
}
is there any problem with ClassLoadingStrategy
?
本文标签: javaCannot inject already loaded type classStack Overflow
版权声明:本文标题:java - Cannot inject already loaded type: class - Stack Overflow 内容由网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:http://www.roclinux.cn/p/1744074471a2529090.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论