在我的Kafka SpringBoot应用程序的@PostConstruct方法中拆分数组时出现问题
在Kafka SpringBoot应用程序的@PostConstruct方法中拆分数组时出现问题，可能是由于以下原因导致的：
- 数据格式错误：首先需要确保数组的格式正确，例如使用逗号或其他符号分隔数组元素。
- 空指针异常：在拆分数组之前，需要确保数组对象不为null。可以通过添加空指针判断来避免此问题。
- 数组越界异常：如果数组的长度不足以满足拆分的需求，将会导致数组越界异常。在拆分数组之前，可以通过判断数组长度来避免此问题。
- 异常处理：在拆分数组的过程中，可能会出现其他异常，例如字符串格式错误等。可以使用try-catch块来捕获异常，并进行相应的处理。
针对以上问题，可以尝试以下解决方案：
- 检查数据格式：确保数组的格式正确，例如使用逗号分隔数组元素。可以通过打印数组内容来验证格式是否正确。
- 添加空指针判断：在拆分数组之前，添加空指针判断，例如使用if语句判断数组对象是否为null。
- 检查数组长度：在拆分数组之前，可以使用if语句判断数组长度是否足够。如果长度不足，可以进行相应的处理，例如给出错误提示或使用默认值。
- 异常处理：使用try-catch块来捕获拆分数组过程中可能出现的异常，并进行相应的处理。可以打印异常信息或进行错误处理。
对于Kafka SpringBoot应用程序中拆分数组的问题，腾讯云提供了一系列云原生解决方案，例如：
- 云服务器CVM：提供高性能、可扩展的虚拟服务器，可用于部署和运行SpringBoot应用程序。
- 云数据库CDB：提供可靠、高性能的数据库服务，可用于存储和管理应用程序中的数据。
- 云函数SCF：无服务器计算服务，可用于处理应用程序中的特定逻辑，例如拆分数组操作。
- 云消息队列CMQ：提供可靠、高性能的消息队列服务，可用于应用程序之间的消息传递和解耦。
以上是腾讯云提供的一些相关产品，您可以根据具体需求选择适合的产品来解决问题。更多产品信息和介绍可以参考腾讯云官方网站：https://cloud.tencent.com/
相关·内容
3回答
如何使用maven生成JAR
、、、、
我有一个运行CLI应用程序的Springboot应用程序。
下面是我的主类：
@SpringBootApplication
public class MyApplication {
@Autowired
GameClient gameClient;
@PostConstruct
public void postConstruct(){
gameClient.runGame();
}
public static void main(String[] args) {
SpringApplication.run(G
浏览 10提问于2018-09-13得票数 1
回答已采纳
我正在开发一个使用Kafka流的应用程序的一些测试，该应用程序还使用SpringBoot1.5，它导入了spring-kafka的1.2版本。详细地说，我使用KafkaEmbedded来避免使用一个真正运行的Kafka实例。
在网络上的许多例子中，我发现这类测试的配置使用注释@DirtiesContext，如下所示(发现)
@RunWith(SpringRunner.class)
@SpringBootTest
@DirtiesContext
public class SpringKafkaReceiverTest {
private static final Logger LOGGE
浏览 2提问于2018-06-05得票数 2
回答已采纳
3回答
由于Kafka有一个基于主题的发布子体系结构，如何使用Kafka处理web应用程序的一对一和组消息部分？我正在使用SpringBoot+Angular堆栈和Docker服务器。
浏览 7提问于2020-05-09得票数 6
回答已采纳
1回答
我用Spring模块创建了一个卡夫卡听众。当我使用JMX打倒所有Kafka侦听器时，Springboot应用程序就会崩溃。在这个应用程序中，除了Kafka使用者之外，我没有其他线程在运行。
浏览 11提问于2021-02-23得票数 0
回答已采纳
我有一个应用程序，它使用2.10.0版本中的SpringBoot 2.10.0 version和kafka。这个应用程序有一个简单的生产者和消费者:发送者使用KafkaTemplate，消费者使用KafkaListener。我试图实现的目标是即使KafkaServer没有运行，也能够启动SpringBoot应用程序。目前，如果没有正在运行的KafkaBroker，应用程序将无法启动，并显示以下错误消息： org.springframework.context.ApplicationContextException:
Failed to start bean 'org.sprin
浏览 216提问于2019-01-25得票数 2
我是Spring和Kafka的新手。我正在做一个使用SpringBoot-kafka的用例，允许用户在运行时创建kafka主题。spring应用程序期望在运行时以编程方式订阅这些主题。到目前为止，我所知道的是，Kafka listener是设计时，因此在启动之前需要指定主题。有没有办法在SpringBoot-Kafka集成中动态订阅kafka主题？
已引用此
我计划实现的当前方法是，不要使用Spring-Kafka集成，而是自己使用这里提到的代码实现Kafka消费者
浏览 0提问于2017-01-08得票数 11
使用Spring JDBC模板，您可以使用一个简单的标志来懒惰地初始化连接。对于Springboot 1.5.x / Spring Kafka 1.3.x部署的Kafka容器工厂，是否有类似的功能？
到目前为止，我看到的最好的答案是禁用autoStart并自己管理启动，在这里捕获启动过程中可能发生的任何异常-
这是唯一的方法吗?在使用KafkaListenerEndpointRegistry自我管理容器的生命周期时，是否有任何注意事项？
Lazy注解是否适用于@KafkaListener，@Configuration类的Kafka配置或类似的组件类？提出这个问题，因为似乎没有一个书面的方法来
浏览 0提问于2019-10-29得票数 1
我有一个SpringBoot应用程序，它加载一些配置，并在带有@PostConstract注释的方法中运行一个长时间的处理。如果应用程序成功完成或出现错误，则应该释放一些资源。
问题是如何使应用程序资源得到最正确的发布？这是否足以使其在@PreDestroy注释方法中生效，或者我也应该捕获@PostConstract注释方法中的异常。
@SpringBootApplication
@Import(MyConfiguration.class)
public class MySpringApplication {
@Autowire
ProcessRunner processRu
浏览 2提问于2018-10-11得票数 3
回答已采纳
我的系统管道是"IBM队列-> Springboot app (消息格式化程序) --> Kafka topic-1 (消息队列) --> Springboot app (消息转换器)-> --> Kafka Top-2(消息队列)“。
我的要求是测试IBM中生成的消息的端到端处理时间，并通过管道进行处理。我有一个带有JMeter的JMeter负载测试脚本，它生成通过管道泵出的大量消息。目前还没有实现Dynatrace监控，但是这里使用了用于Kafka监控的汇合控制中心。
您能否建议一些可能的选项来度量Springboot应用程序处理的消息的个人和端到端处
浏览 5提问于2019-11-26得票数 0
回答已采纳
我在一个springboot应用程序中有一个简单的kafka消费者侦听器，如下所示：
@KafkaListener(topics="mytopic")
public void receive(String message) {
LOGGER.info("received message='{}'", messge);
}
在某些特定情况下，我想拒绝该消息，但我希望系统在特定时间后再次向我提出该消息；
我该怎么做呢？
注意:我也希望kafka的配置是定制的(而不是默认的springboot结构)
浏览 11提问于2019-07-11得票数 1
回答已采纳
1回答
我有一个使用LogBack日志的Spring应用程序。在日志记录中，我配置了一个Apache附录。它很好用。
但是问题是，在Bean的@PostConstruct方法中已经有了一个日志输出。
据我所见，卡夫卡附录(与卡夫卡的连接)的init并不像豆子的init那么快。因此，bean的@PostConstruct方法中的"Bean是初始化的“的第一个日志输出丢失了(有时)。
@PostConstruct
void afterInit () throws Exception
{
Logger logger = LoggerFactory.getLogger ("tokafk
浏览 7提问于2022-03-13得票数 0
回答已采纳
我是新卡夫卡，弹力靴，并试图整合卡夫卡和弹性搜索在我的弹力启动应用程序。
当我尝试运行springboot应用程序时，我会看到下面的错误：
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaListenerContainerFactory' defined in class path resource [org/springframework/boot/autoconfigure/kafka/KafkaAnnotationDrivenConfi
浏览 14提问于2019-10-04得票数 3
1回答
Java 8，
Flink 1.9.1，
Azure事件中心
我不能再连接到蔚蓝事件中心与我的flink项目，从2020年1月5日。我在几个spring引导应用程序中也有同样的问题，但是当我升级到SpringBoot2.2.2时，这个问题得到了解决，SpringBoot2.2.2也将Kafka客户端和Kafka依赖项更新为2.3.1。我试图更新Flink的kafka依赖，但没有成功。我还提交了一个问题
2020-01-10 19:36:30,364 org.apache.kafka.clients.NetworkClient -消费客户端=消费者-1，groupId=**** Bootst
浏览 0提问于2020-01-10得票数 1
回答已采纳
我正在开发一个springboot应用程序，它依赖于另一个springboot应用程序。我想在父级springboot应用程序中包含大多数bean，而不是一个。
如何在不接触ParentApplication类的情况下排除父包已经扫描的一个springboot bean？
我尝试过但不起作用的方法：
1:在我的应用程序类中使用排除筛选来筛选出特定的bean类。
2:我还尝试排除bean类和父配置类。
3:将DisposableBean接口添加到我想要排除的bean类中，并在运行时销毁它。
下面是我的应用程序启动器配置类和父类。
我的MyApplication.class: package co
浏览 118提问于2018-08-29得票数 0
我有一个带RestRepostory的SpringBoot 2.2.4.RELEASE，像这样
import io.micrometer.core.instrument.Gauge;
import io.micrometer.core.instrument.MeterRegistry;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.PostConstr
浏览 117提问于2020-05-13得票数 2
我有一个简单的springboot引导应用程序运行在码头容器与以下配置。
@Configuration
public class ProducerConfiguration {
private static final String KAFKA_BROKER = "kafka:9092";
@Bean
public ProducerFactory<String, String> producerFactory() {
return new DefaultKafkaProducerFactory<>(produc
浏览 1提问于2020-03-07得票数 1
回答已采纳
尝试将使用springboot的springboot应用程序从2.8.4升级到2.9.3版本。
我遵循这里的说明，将kafka版本3.2.3作为一个单独的依赖项。
我的依赖关系如下所示
implementation("org.springframework.kafka:spring-kafka:2.9.3") {
exclude group: "org.apache.kafka", module: "kafka-streams"
exclude group: "org.apache.kafka", module:
浏览 22提问于2022-11-30得票数 0
回答已采纳
这样的情况可能吗？
有一个应用程序"XYZ“(其中没有Kafka)公开了REST。它是一个SpringBoot应用程序，它与角应用程序进行通信。
创建了一个新的应用程序(SpringBoot)，它希望使用Kafka，并需要从"XYZ“应用程序中获取数据。它想用卡夫卡来做这个。
"XYZ“应用程序有一个示例端点[GET] api/message/all，它显示所有消息。
有没有一种方法可以将Kafka直接连接到这个端点并从中读取数据？简而言之，卡夫卡的想法是直接从EP消费数据。两个微服务之间的通信，其中一个微服务没有卡夫卡。
你对解决这种情况有什么建议。因为我想这个选择是
浏览 3提问于2022-02-05得票数 0
我试图在我的SpringBoot应用程序中创建@PostConstruct中的实体
@PostConstruct
void load() {
for (int i = 0; i < 10; i++) {
Item item = new Item();
item.setRating(Math.random());
imageList.add(new Image());
item.setImages(imageList);
itemRepos
浏览 5提问于2022-05-28得票数 0
回答已采纳
1回答
在springboot中，我有一个取自db的cron表达式。问题是db是与应用程序一起部署的，并且cron表达式是作为种子数据给出的，但是当应用程序启动时，在创建db之前会调用调度程序，并且我得到一个空指针。我试着使用@PostConstruct，但它不起作用。有什么建议吗？
浏览 19提问于2021-08-24得票数 0
我继承了一个springboot应用程序。此应用程序具有类似于以下内容的服务：
@Service
public class MyService {
String param1 = "";
String param2 = "";
public void doStuff() {
// do stuff assuming the parameters param1 and param 2 of this autowired service have already been initialized
}
}
，此服务是自另一种类似于以下服
浏览 3提问于2022-11-17得票数 1
回答已采纳
在其中一个例子中，当消费者服务重新启动时，它会导致重新处理发送给Kafka的所有记录。
Kafka Broker: 0.10.0.1
Kafka producer Service: Springboot version 1.4.3.Release
Kafka Consumer Springboot Service: Springboot version 2.2.0.Release
现在，为了研究这个问题，我想在开发/本地环境中重新创建这个场景，这个场景不会发生！
可能的原因是什么？
如何检查，当我们发送Acknowledgement.acknowledge();时，是否从客户端处理了记录
消费
浏览 3提问于2020-07-10得票数 0
我希望在所有测试之前启动一次服务器，然后在所有测试执行之后关闭服务器。
在SpringBoot1.3中，我可以创建一个带有@Component的@PostConstruct，以便在执行测试之前启动一次服务器，然后在所有测试执行后@PreDestroy停止服务器。
升级到SpringBoot1.5之后，@PostConstruct在每个 @Test方法之前被调用。@PreDestroy被调用为每个 @Test，但只有在所有测试都执行之后才会调用！
什么改变了，或者我现在该怎么做？
浏览 10提问于2017-04-12得票数 1
回答已采纳
我在我的项目中使用了Kafka和Springboot，现在我有了外部Kafka集群和SpringBoot微服务项目。
使用yml文件，我成功地创建了Kafka生产者和消费者，然后应用程序和kafka就可以很好地通信了。
现在我想在我的sprintboot项目中使用嵌入式kafka。类似于嵌入在Activemq代码之后。
spring:
# Embedded ActiveMQ Configuration Example
activemq:
broker-url: vm://embedded?broker.persistent=false,useShutdownHook=fa
浏览 5提问于2019-01-18得票数 1
1回答
Spring中的缓存加载
、、、、
我有一个缓存类，它在应用程序启动前从.properties文件中加载属性，这个类位于一个简单的java项目中。它把所有东西都注销了，我需要把这个项目转换成springboot应用程序。
我可以使用什么注释来实现缓存加载？？
目前，我编写的代码就像我的spring引导应用程序从@postconstruct开始，因为我没有使用web.xml来加载servlet。
@RestController
public class ConfigServlet {
@PostConstruct
public void init() {
//business logic
浏览 3提问于2020-09-21得票数 0
我有一个Springboot应用程序。使用此配置：
kafka:
consumer:
listener:
ack-mode: MANUAL_IMMEDIATE
广告给这个消费者：
@KafkaListener(topics = "test", groupId = "group_id")
public void consume(String message, Acknowledgment ack) throws IOException {
ack.acknowledge();
}
但是
浏览 6提问于2020-03-30得票数 3
回答已采纳
我们的工作环境是一个被篡改的卡夫卡。我想知道在这种场景中部署kafka连接器和kafka流应用程序的最佳实践。目前，我们正在将每个连接器和流部署为springboot应用程序，并作为systemctl微服务启动。我不认为在对接每个卡夫卡连接器和流明显的优势。请给我提供同样的见解。
浏览 1提问于2018-02-20得票数 4
回答已采纳
2回答
我正在尝试在我的springboot应用程序中加载一次属性。
实际上，我已经创建了一个类来做到这一点：
@Configuration
@PropertySource(value = { "classpath:parameters.properties", "classpath:iot.properties" })
public class PropertiesHelper {
@Autowired
protected Environment env;
private static Environment properties;
浏览 10提问于2017-08-08得票数 0
我想使用kafka和springboot实时地从文件中发送数据，我已经测试了这个代码，用postman以JSON格式将数据发送到kafka主题。
@RestController
public class OrderController {
@Autowired
private KafkaProducerService kafkaProducerService;
@PostMapping("/post")
public void order(@RequestBody Order order) {
kafkaProduce
浏览 7提问于2022-11-07得票数 0
谷歌云平台中的卡夫卡virual机器地址是xx.xx.xxx.xxx。
从我的本地春季引导应用程序(通常连接到本地主机:本地机器的kafka服务器的9092)，我将它更改为GCP的虚拟机的ip为xx.xx.xxx.xxx:9092。
但是服务器启动时发出警告。
2020-04-05 15:30:41.356 WARN 7968 --- [| adminclient-4] org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-4] Connection to node -1 could not
浏览 1提问于2020-04-05得票数 0
回答已采纳
我正在开发一个Spring Boot应用程序，它使用以Kafka主题为源的Spring集成流。我们的集成流开始使用一个包含带有springframework.cloud.stream.annotation.Input和输出注释的SubscribableChannels的接口。这些配置为通过云配置和spring.cloud.stream.kafka.bindings从Kafka读取。
当应用程序第一次启动时，它会立即开始读取Kafka主题。这是一个问题，因为应用程序需要初始化一些本地的、不可持久的数据库，然后才能开始正确处理传入的Kafka消息。
我们目前正在使用@PostConstruct在K
浏览 0提问于2018-04-24得票数 1
我在我的应用程序中使用SpringBoot依赖项来使用Kafka。
在我的Kafka实例启动并运行之前，一切都很好，但是问题是我的unit&integration测试，它们在我的本地运行，但在我的部署管道中运行得很好(这很明显，因为应用程序在运行测试时试图连接构建管道中的Kafka实例，却找不到任何)，所以最终得到了以下错误：
[Consumer clientId=consumer-1, groupId=biz-web-group-test] Connection to node -1
could not be established. Broker may not be avail
浏览 2提问于2019-05-16得票数 1
我正在使用camel-spring-boot-starter运行一个kafka消费者应用程序。SpringBoot应用程序实现CommandLineRunner。以下属性是在我的应用程序中配置的。 camel.springboot.main-run-controller=true 我试图在端口8080上公开springboot执行器指标，但在将端点公开为非web应用程序时，我面临着挑战。url http://localhost:8080/actuator/metrics给出404状态代码。 我如何为我的用例公开HTTP端点上的致动器“/metrics”？ 注意:执行器和驼峰管理依赖项在类路径
浏览 15提问于2021-06-22得票数 0
我对有个问题。问题是，我有一个bean，它一创建就会写到Kafka (带有@PostConstruct注释的方法)，因此我自动创建了适当的MessageChannel，并在application.yml中设置了目的地和绑定器属性。事情是这样的：
@Component
@RequiredArgsConstructor
public class Sender
{
private final MessageChannel output;
@PostConstruct
public void start()
{
output.send(new Gener
浏览 0提问于2017-05-30得票数 2
回答已采纳
2回答
绑定中的输出绑定
、、
在这个中，你不能只做一个输出
但是我只需要用做一个输出
我该怎么办？
一些文章说，使用org.springframework.cloud.stream.function.StreamBridge，但它不适用于我
我使用StreamBridge将主题发送给Kafka，但是Kafka没有为我的Spring应用程序生成主题
这是我的application.yml并生成主题代码
// producer Springboot application
spring.cloud.stream:
kafka:
binder:
brokers: {A
浏览 4提问于2021-08-02得票数 1
回答已采纳
我的SpringBoot应用程序正在本地主机上运行，但我希望它与远程服务器下载的Kafka连接，例如123.45.6.789。我能够从mobaxTerm终端生成和使用消息，但由于这个错误，我的springboot应用程序无法与kafka连接。
WARN[0;39m [35m18788[0;39m [2m---[0;39m [2m[ntainer#0-0-C-1][0;39m
[36morg.apache.kafka.clients.NetworkClient [0;39m [2m:[0;39m [Consumer
clientId=consumer-fooss-1, groupId=fo
浏览 1提问于2022-09-22得票数 1
回答已采纳
1回答
我正在开发一个采用微服务架构的springboot项目，我使用Kafka作为事件总线在其中一些人之间交换数据。我还进行了Junit测试，测试了我的应用程序中不需要总线的部分，以及使用嵌入式Kafka broker来要求总线的其他部分。
我遇到的问题是，当我启动所有测试时，它们花费了这么多时间，而且失败了，因为每个测试都试图连接到嵌入式Kafka broker (连接不可用)，而他们不需要Kafka总线来完成他们的任务。
是否有可能禁用卡夫卡组件的加载这些测试，并只允许他们需要它？
浏览 6提问于2022-07-03得票数 1
1回答
我在SpringBoot2.x应用程序中使用SpringCloudStream3.x来使用Kafka主题的消息。
我希望有一个侦听器在某些自定义标头值上有条件地使用消息，如按照
@StreamListener(value = "someTopic", condition = "headers['SomeHeader']=='SomeHeaderValue'")
public void onMessage(Message<?> message) {
LOGGER.info("Received: {}"
浏览 16提问于2020-12-17得票数 1
回答已采纳
尝试使用Springboot-Kafka进行实践。有几个疑问。这些参数对于application.yml中的Kafka调优有效吗 fetch-max-bytes: 52428800 你知道这是不是Kakfa上的有效属性？我在我的springboot项目中的application.yml中使用它来控制我的消费者轮询行为。其次，在此块中是否存在由KafkaListener内部启动的多个线程 @KafkaListener(id = "instance1", groupId = "${spring.kafka.consumer.group-id}", topics =
浏览 55提问于2021-08-05得票数 0
回答已采纳
将数据从mysql传递到kafka produce的最佳方式是什么 我知道有很好的kafka连接器。然而，我想使用springboot框架。因为我需要转换数据并与其他http结果合并，然后我想产生数据到kafka。 那么有没有什么好的例子，github，博客wahtever~？
浏览 44提问于2020-07-21得票数 1
当我在本地运行时，我可以看到正在收集kafka.consumer.。当我部署我的服务时，我发现这些指标并不存在。
我使用了kafka版本的1.11.0、java 11和SpringBoot2.2。
我怎么才能确定缺了什么？
浏览 3提问于2019-10-30得票数 0
回答已采纳
当将项目从Springboot 2.0升级到2.1时，我们还将spring-kafka-integration从3.0.1升级到3.2.1。在这样做的过程中，我们的测试现在都无法启动，原因是：
org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-1, groupId=x] Connection to node -1 could not be established. Broker may not be available.
org.apache.kafka.clients.NetworkClient
浏览 0提问于2019-05-03得票数 4
回答已采纳
2回答
我想监视Kafka指标，但不幸的是，在/驱动器/prometheus端点下没有任何与Kafka相关的信息。我的装置里有遗漏什么吗？
应用程序依赖关系：Kotlin 1.4.31，SpringBoot2.3.9，Spring 2.6.7，反应堆Kafka 1.2.5，Kafka客户端2.5.1
应用程序配置
management:
server:
port: 8081
endpoints:
web:
exposure:
include: health,info,metrics,
浏览 6提问于2021-03-19得票数 2
回答已采纳
我按照以下方式配置了一个Apache FtpServer：
@Component
public class FtpDummyServer {
private FtpServer server;
@PostConstruct
public void init() throws FtpException {
..some initialization
this.server = serverFactory.createServer();
this.server.start();
}
@PreDestroy
public void stop() {
this.s
浏览 0提问于2016-03-31得票数 0
回答已采纳
我必须发布来自kafka主题的消息到lambda来处理它们并使用springboot应用程序存储在数据库中，我做了一些研究并发现了一些可以使用kafka public Function<KStream<String, String>, KStream<String, String>> process(){}的消息，但我不确定这是否只用于将所消耗的消息发布到另一个kafka主题，还是可以用作一个事件源来进行lambda，我需要一些关于消费和将所消费的kafka消息转换为事件源的指导。
浏览 5提问于2022-08-11得票数 -2
1回答
我正在使用Apache Camel创建一个应用程序来将消息从AMQP传输到Kafka。代码也可以在这里看到-
我想用spring，amqp和kafka starters创建一个独立的SpringBoot应用。创建了如下路由
@Component
public class QpidToKafkaRoute extends RouteBuilder {
public void configure() throws Exception {
from("amqp:queue:destinationName")
.to("kafka
浏览 64提问于2020-03-13得票数 0
我正在使用Spring5、JDK1.8、SpringBoot 2.0开发一个Java应用程序(微服务)。我得到了一个帮助类，其中我使用@PostConstruct加载了一个hashmap，如下所示：
帮助类：-
private final Map<String, CommonData> empMap = new HashMap<>();
@PostConstruct
public void init() {
loadEmpMap();
}
private void loadEmpMap() {
List<EmpMap> employee
浏览 0提问于2018-07-30得票数 1
我正在使用SpringBoot2.2.0.M4和Kafka2.2.0试图构建一个基于示例的应用程序。当我为我的主题启用侦听器时，我会在使用者上得到以下错误。
无法建立到节点-1 (localhost/127.0.0.1:9092)的AdminClient clientId=adminclient-2连接。代理可能不可用.
下面是在我的应用程序属性中定义的。
kafka.bootstrapAddress=172.22.22.55:9092
下面是@KafkaListener注释的方法。
@KafkaListener(topics = "add_app", groupId = &#
浏览 0提问于2019-07-24得票数 4
我们的应用程序被部署到一个k8s集群中，在该集群中，TLS证书每小时都会被非常积极地更新。应用程序还使用在application.yml中配置的相互TLS身份验证连接到Kafka。
据我所知，密钥库和信任库都以一种不可变的方式加载到SSLContext中，而且不能很容易地替换它。最简单、看似可行的解决方案可能是重新启动所有侦听器，如下代码所示：
@Autowired
private KafkaListenerEndpointRegistry messageListenerContainer;
@PostConstruct
public void setupTlsCertificateRefr
浏览 4提问于2021-12-17得票数 0
1回答
我们有一个现有的应用程序，我们监控所有微服务的kafka事件和参考数据。我们绕过了SpringBootAdmin，希望将其集成到我们现有的监控应用程序中。
在我们的所有微服务中添加了SpringBoot客户端启动依赖，并在监视应用程序中添加了SprigBoot管理服务器启动依赖。所面临的问题是无法访问我们以前的UI。UI由SpringBoot Admin接管。
因此，想知道是否有可能将这个管理ui作为一个单独的组件包含在我们的UI中/或者我们是否可以将它作为一个iframe嵌入。还是可以访问某些单击事件的SpringBoot管理UI .？
浏览 1提问于2019-10-20得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
