我正在使用spring Kafka的应用程序中设置用于JUnit测试的Embedded-Kafka。为zookeeper日志目录设置的位置/属性是什么。使用Embedded-Kafka时，默认情况下我没有名为server.properties或zookeeper.properties的文件，它会在Windows上的临时文件夹中创建<em
浏览 23提问于2019-04-19得票数 2
我正在尝试在Windows操作系统上进行简单的kafka配置。我的zookeeper和kafka安装使用默认配置(数据和日志目录路径除外)。我可以启动kafka并生成/消费消息，没有问题；但是，当broker尝试删除旧消息时(我将日志保留设置为100ms)，我得到以下错误： java.nio.file.FileSystemExceptionat kafka.log.LogSegment.changeFile
浏览 544提问于2018-08-02得票数 24
回答已采纳
2回答
当我在没有Docker的情况下运行kafka和zookeeper时，我可以在/tmp/kafka-logs目录中看到主题partitions日志文件。现在使用Docker，即使我在docker-compose.yml的Volumes部分中指定了日志目录，我也看不到docker VM中的文件，比如“TOPICNAME-PARTITIONNUMBER”。您是否知道在Docker VM
浏览 0提问于2016-09-09得票数 2
下面是我为解决这个问题所采取的步骤：发射卡夫卡：.\bin\windows\kafka-server-start.bat .与meta.properties中存储的clusterId Some(BaPSk1bCSsKFxQQ4717R6Q)不匹配。代理试图加入错误的集群。配置的zookeeper.connect可能是错误的。\config\server.properties动物园管理员控制台时，返回：
INF
浏览 0提问于2020-01-06得票数 16
我一直在使用 (2.11)，昨天我不得不出于某种未知的原因强制终止该进程。at org.apache.zookeeper.server.persistence.FileTxnSnapLog.restore(FileTxnSnapLog.java:222) at org.apache.zookeeper.server.ZooKeeperServer.startdata(ZooKeeperSe
浏览 2提问于2020-01-11得票数 29
下面是我为解决这个问题所采取的步骤：
发射卡夫卡：.\bin\windows\kafka-server-start.bat .与meta.properties中存储的clusterId Some(BaPSk1bCSsKFxQQ4717R6Q)不匹配。代理试图加入错误的集群。KafkaServerStartable.scala:44) at kafka.Kafka$.main(Kafka.scala:84
浏览 1提问于2019-12-25得票数 33
回答已采纳
在启动之前的脚本中，我删除旧容器docker rm my_kafka_container，然后运行码头。动物园管理员正常启动，在文件meta.properties中，从以前的启动开始就有旧的集群id，但是由于某种原因，meta.properties集群/ id无法找到这个id，而是创建了一个新的不是存储在meta.properties中的id。Configured zookeeper.connect may
浏览 0提问于2020-01-04得票数 28
回答已采纳
Kafka数据存储在本地Windows文件夹中，以便持久化。Windows文件夹通过docker卷映射到Kafka码头图像。我可以创建主题、发布和使用消息。UPD:下面你可以找到我用来运行Kafka的文件的内容：services: image: zookeeper
浏览 14提问于2018-01-05得票数 11
回答已采纳
我正试图在我的开发计算机上同一台主机上启动3台动物园管理员服务。这显然不是我在生产中要做的事情，我这样做是为了探索测试/开发计算机中的容错性和Kafka依赖性。我已经在我的dev计算机上安装了Kafka 2.5.0，并且我成功地在主机上设置了3个Kafka服务，并在同一台主机上设置了一个动物园管理员服务。使用的动物园管理员脚本和软件包，随卡夫卡包。simpleGroup=ka
浏览 6提问于2020-05-17得票数 1
回答已采纳
我刚刚在我的Windows机器上安装了Kafka (来自Confluent平台)。我启动了Zookeeper和Kafka，并创建主题，生产和消费他们的作品。\bin\windows\kafka-topics.bat -zookeeper 127.0.0.1:2181 --topic foo --create --partitions 1 --replication-factor\bin\windows\kafka-topics.bat -zoo
浏览 8提问于2018-06-08得票数 11
2回答
我从链接下载卡夫卡
我把它解压缩到一个名为Kafka的文件夹中的C驱动器。我将zookeeper.properties文件中的dataDir修改为C:/kafka/kafka_2.11-1.0.0/动物饲养员-data，并在server.properties for log.dirs中更改为C:/kafka/kafka</e
浏览 3提问于2017-11-10得票数 0
回答已采纳
按照中的说明，启动动物园管理员，然后在Windows 10上启动kafka服务器代理。在日志加载过程中，其中一个线程出现了错误: org.apache.kafka.common.KafkaException: Found目录C:\kafka_2.12-2.3.1\data\kafka，“Kafka的日志目录(和子目录)应该只包含Kafka
浏览 5提问于2019-11-04得票数 1
2回答
我正在尝试构建一个基于的管道，其中Kafka使用file Source连接器读取文件。使用 for the Elastic Stack，我想将Logstash注册为“快速入门-数据”主题的消费者，但我暂时失败了。这是我的logstash.conf文件： kafka { topics => 'quickstart-data[ 'elasticse
浏览 5提问于2018-04-25得票数 1
我有三个节点的kafka集群，在kafka日志目录中有__consumer_offsets-XX，许多日志文件作为100 as的日志文件用于磁盘位置超过90%，excutes命令：
./bin/kafka-configs.sh --zookeeper localhost:2181 --describe --entity-name __consumer_offsets --entity-typeto
浏览 1提问于2017-01-02得票数 2
1回答
我已经使用下面的命令直接从Zookeeper删除了topic，之前没有从Kafka中执行删除：现在我看到的是，该主题出现在集群中至少一个代理的log.dirs中。现在，当我尝试从kafka中删除时，会抛出以下错误
Error while ex
浏览 0提问于2020-03-18得票数 0
我正在尝试通过命令行按照Apache Kafka网站上的指南创建Kafka主题。运行该命令时：我得到的错误如下：
Error while executing topic command replication factor: 1 larger than availab
浏览 2提问于2015-10-13得票数 58
10回答
在我运行了大约10分钟的代码之后，Kafka在以下错误中失败了：
2017-11-07 16:48:01,320致命关闭代理，因为C：\kafka\kafka_2.12-1.0.0\kafk
浏览 11提问于2017-11-07得票数 30
有没有一种方法可以在每次运行之前删除主题中的所有数据或删除主题？
是否可以修改KafkaConfig.scala文件以更改logRetentionHours属性？我正在使用生产者从某个地方获取数据，并将数据发送到消费者消费的特定主题，我可以在每次运行时删除该主题中的所有数据吗？我只希望每次在主题中都有新的数据。有没有办法以某种方式重新初始化主题？
浏览 0提问于2013-07-19得票数 94
回答已采纳
2回答
我想在我的centos 6.5机器上安装kafka。在kafka安装教程中，我了解到它需要zookeeper才能运行。我已经安装了hbase，它也在内部使用zookeeper服务，zookeeper服务只在我启动hbase服务时启动。
那么为了安装kafka，我需要单独安装zookeeper吗？请提个建议。
浏览 4提问于2016-04-20得票数 0
以下是Logstash 5服务器上的配置kafka {bootstrap_servers => "zk_server:2181它也是正确配置的。
我仍然看不到/var/log/logstash/logstash.stdout中的数据。logstash是用-log.level=debug启动的，但我在日志/
浏览 5提问于2016-07-11得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
