spring相关内容

Spring-AOP:@在异常:java.lang.IlLegalArgumentException:引用的错误类型不是批注类型

我是AOP和AspectJ的新手。我正尝试围绕元素类型为TYPE的自定义注释编写一个自定义逻辑。我还想在我的注释下使用这些参数来在环绕方法中编写一个定制逻辑。我收到了下面提到的错误。我试着阅读了多个来源,大多数来源都与使用@annotation有关。我发现很难理解这一点。谁能解释一下,为什么以下@within的方法不适用于一些明显的例子? Annotation(Slf4jTrace.java ..
发布时间:2022-05-08 23:10:03 Java开发

如何将事件发送到PCF中应用程序的所有实例

我无法找到向Pivotal Cloud Foundry中的所有应用程序实例发送/广播消息的方法。我们如何将某些事件通知给所有应用程序实例?如果我们使用HTTP请求,PCF路由器会将其分派给应用程序的单个实例。我们如何解决这个问题? http @florian所说的可能是更安全的选择,但如果您想要快速简单的东西,您可以使用X-CF-APP-INSTANCE头直接向应用程序实例发送推荐答案 ..
发布时间:2022-05-07 11:36:42 Java开发

Java 8-CrudRepository<;Developer,Long&>类型中的方法save(S)不适用于参数(可选<;Developer&>)

我开始使用Spring框架进行Java开发,为了获得比Hello World更复杂的东西,我找到了本教程并尝试遵循。 https://www.toptal.com/spring/beginners-guide-to-mvc-with-spring-framework 我发现的问题是,由于扩展“CrudRepository”的My类返回一个可选的<;Skills>和可选的<;De ..
发布时间:2022-05-06 22:22:18 Java开发

春季的卡夫卡消费者我可以通过编程重新分配分区吗?

我刚接触Kafka,并且使用@KafkaListener(Spring)来定义Kafka消费者。 我想检查是否可以在运行时手动将分区分配给使用者。 例如,当应用程序启动时,我不想使用任何数据。我目前正在使用@KafkaListener(autoStartup=false ... )用于该目的。 在某个时刻,我应该(从应用程序的另一部分)收到包含要处理的分区ID的通知,因此我希望跳过该分区的 ..
发布时间:2022-05-06 18:43:20 Java开发

自定义对象映射器的问题

我正在尝试生成一些消息到Kafka主题,我想自定义Jackson对象映射器以将我的LocalDateTime序列化为这样的字符串2021-07-08T16:43:02Z 但这两个都不 @Configuration public class WebConfiguration { ... @Bean public ObjectMapper objectMappe ..
发布时间:2022-05-06 18:20:01 Java开发

Spring Kafka@DltHandler注释方法在非阻塞重试实现中未正确接收标头

我正在尝试用Spring Kafka实现一个非阻塞的Retries。根据文档here,在完成在@KafkaListnener中设置的所有尝试之后,我们可以设置一个处理程序方法来处理来自DLT主题的消息。我打算捕获DLT处理程序方法上的一些标头,如以下代码所示: @DltHandler fun processaDlt( @Payload mensagem: String ..
发布时间:2022-05-06 18:08:11 其他开发

如何在启动上下文之前在内存中加载压缩的主题

我使用的是Kafka中的压缩主题,在应用程序启动时将其加载到HashMap中。 然后,我监听消息的普通主题,并使用从压缩的主题构造的HashMap来处理它们。 在开始收听其他主题之前,如何确保压缩的主题已完全阅读且HashMap已完全初始化? (RestController相同) 推荐答案 实现SmartLifecycle,将地图加载到start()中。请确保phase早于任何其他需 ..
发布时间:2022-05-06 14:54:20 其他开发

如何获得KafkaListener消费者

我使用SpringBoot 2.0.4.RELEASE的Spring-Kafka。 并使用KafkaListener获取消息 现在我要重置我的组的偏移量 但我不知道如何获得群的消费者 @KafkaListener(id="test",topics={"test"},groupId="group",containerFactory="batchContainerFac ..
发布时间:2022-05-06 14:48:11 其他开发

创建不带注释的KafkaListener&;不带弹簧靴子

我正在尝试为一个主题创建一个Kafka Consumer,而不使用@KafkaListener注释。我之所以要这样做,是因为我试图在不使用SpringBoot的情况下,基于Application.Properties动态创建侦听器。 我想最好的方法是手动创建一个KafkaListenerContainerFactory。谁能提供一个在它自己的类中如何做到这一点的例子吗? 推荐答案 ..
发布时间:2022-05-06 14:43:50 其他开发

春天·卡夫卡听着regex

我正在尝试使用以下代码收听新创建的主题,但不起作用。您能告诉我下面的代码是否正确吗? public class KafkaMessageListener { private static final Logger LOGGER = LoggerFactory.getLogger(KafkaMessageListener.class); private final Proce ..
发布时间:2022-05-06 14:01:49 Java开发

使用Vertica数据库系统获取Java JPA的行级锁

当多个线程试图更新同一个表中的不同记录时,我收到死锁X。在使用Vertica DB系统和Java JPA时,有没有方法获得行级锁而不是表级锁? 推荐答案 否 Vertica是一款专用的大数据数据库,在15年前设计时考虑到了OLAP工作负载--损害了对OLTP工作负载的支持。 行级锁定是OLTP数据库的特点。 Vertica可以在没有任何压力的情况下提交和回滚数百万行的 ..
发布时间:2022-04-27 15:29:02 其他开发