小编Tom*_*Tom的帖子

我的消费者配置如下

package com.example.kafka.config;

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;

import java.util.HashMap;
import java.util.Map;

@EnableKafka
@Configuration
public class KafkaConsumerConfig {
    @Bean
    public ConsumerFactory<String, String> consumerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:2181");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "group-tenent1-id");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        return new DefaultKafkaConsumerFactory<>(props);
    }
    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String>
                factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }

}

但是，当应用程序启动时，我看到以下内容不断输出

由于节点 -1 已断开连接，已取消相关 ID 为 1 的进行中 API_VERSIONS 请求 …

我试图在 SQL 模式下使用 h2 数据库。我能够创建一个全部大写的模式，并在其下创建一些表。但是，除非我匹配所有大写的架构名称，否则我在休眠上运行的应用程序似乎无法工作。我认为 h2 可以在 JDBC 连接字符串中使用 IGNROECASE=TRUE 进行配置。我错过了什么吗？

我试图测试运行我公司的 terraform 模块。

然后运行 ​​terraform apply 出现以下错误。

\xe2\x95\xb7\n\xe2\x94\x82 Error: Missing required argument\n\xe2\x94\x82\n\xe2\x94\x82 The argument "domain" is required, but was not set.\n\n

我搜索了所有项目文件夹，包括文件夹中的文件.terraform，但找不到该变量。

我如何知道哪个 terraform 脚本给出了该错误？