作者热门文章
- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个 Spring boot 项目,它具有使用 kafka 进行日志记录的依赖项。我无法摆脱所述依赖项,因为我的逻辑需要来自该依赖项的代码
我想在本地启动所述应用程序而不运行kafka,这样我就可以测试我的简单数据库查找代码。
我尝试过禁用自动配置
spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration
我尝试通过 bean 配置将missingTopicsFatal 设置为 false
@Bean(name = "kafkaListenerContainerFactory")
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(
ConsumerFactory<Object, Object> kafkaConsumerFactor,
ConcurrentKafkaListenerContainerFactoryConfigurer configurer) {
ConcurrentKafkaListenerContainerFactory<Object, Object> factory =
new ConcurrentKafkaListenerContainerFactory<>();
configurer.configure(factory, kafkaConsumerFactor);
ContainerProperties containerProperties = factory.getContainerProperties();
containerProperties.setMissingTopicsFatal(false);
...
return factory;
}
但显然该设置已经是错误的,因为我的应用程序运行没有失败,只是 tomcat 不想打开监听端口
我遇到的所有其他解决方案都涉及更改使用 kafka 的代码;在本例中,是我正在使用的依赖项。但我无权更改所述依赖项。
应用程序启动,但 spring 拒绝打开监听端口并继续循环并出现错误
Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
应用程序在 kafka 本地运行的情况下运行良好,但由于 kafka 的资源使用,现在单纯的打字行为很慢。请帮忙。
最佳答案
在我看来,您的主要问题是本地 kafka 安装的资源使用情况。也许先看一下它的配置和数据。也许从头开始并清除所有本地数据?
或者,您可以在进程内运行 KafkaServer,在您的主类中类似这样:
Properties kafkaProperties = new Properties();
kafkaProperties.setProperty("broker.id", "1");
kafkaProperties.setProperty("host.name", "localhost");
kafkaProperties.setProperty("listeners", "PLAINTEXT://localhost:" + kafkaPort);
kafkaProperties.setProperty("log.dir", Files.createTempDir().getAbsolutePath());
KafkaConfig kafkaBrokerConfig = new KafkaConfig(kafkaBrokerConfig);
KafkaServer kafkaServer = new KafkaServer(kafkaBrokerConfig, Time.SYSTEM);
kafkaServer.startup();
或者您可以从 Docker 运行 Kafka。参见例如docker-compose 文件 https://github.com/confluentinc/examples/tree/5.4.1-post/cp-all-in-one-community .
您可能只需要动物园管理员和经纪人:
docker-compose.yml:
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:5.4.1
hostname: zookeeper
container_name: zookeeper
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
broker:
image: confluentinc/cp-kafka:5.4.1
hostname: broker
container_name: broker
depends_on:
- zookeeper
ports:
- "29092:29092"
- "9092:9092"
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
关于java - 如何在没有kafka服务器的情况下运行spring boot,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61224895/
我是一名优秀的程序员,十分优秀!