我跟踪了一个。在我重新启动Linux之前，一切都很好。重新启动后，当我尝试使用kafka-console-consumer.sh使用队列时，会出现以下错误。
$ ~/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TutorialTopic --from-beginning
2016-02-04 :16:54,944警告console-consumer-6966_bob-kafka-storm-1454577414492-8728ae43，，在试图重新平衡时没有找到经纪人。(kafka.consum
浏览 9提问于2016-02-04得票数 5
我在我的Linux支架上解开了Kafka，然后我做到了： 启动zookeeper： ./zookeeper-server-start.sh 输出： USAGE: ./zookeeper-server-start.sh [-daemon] zookeeper.properties 启动kafka-server ./kafka-server-start.sh 输出： USAGE: ./kafka-server-start.sh [-daemon] server.properties [--override property=value]* 然后我尝试创建主题 ./kafka-topics.sh
浏览 119提问于2020-03-26得票数 0
回答已采纳
在我的linux服务器中按CTRL+c时，我的Kafka服务器正在关闭。我该怎么避免呢？或者，是否还有其他*.sh文件可以启动kafka服务器，而不存在按CTRL+c的问题？
浏览 0提问于2016-11-22得票数 0
回答已采纳
1回答
根据其，Apache默认登录到/tmp/kafka-logs。
因为/tmp在Linux中是由root拥有的，所以对我来说，这意味着您必须以root的身份运行Kafka，这样它才能正确地登录到那个位置。然而，出于安全考虑，我不希望它作为根用户运行，所以我试图找出我的选项是什么。我相信我必须在以下两者中作出选择：
使用-Dkafka.logs.dir命令行开关为要写入的日志指定一个不同的位置(不属于root)；或
提前修改系统(即在启动Kafka之前)，以便/tmp/kafka-logs由将启动Kafka的用户拥有(或者，通常确保Kafka用户拥有对该目录的r/w/x的正确权限)；或
浏览 4提问于2016-09-28得票数 0
回答已采纳
1回答
如何将不同VM上的两个kafka集群连接在一起？
在我的Windows 上，使用IP地址：192.168.2.22，我从下载了docker-come.yml，并在cmd控制台中使用docker-compose up -d启动了它。
创建主题：
docker exec kafka1 kafka-topics --bootstrap-server localhost:9092 --create --topic my-Windows-Topic-1
以不同的方式检查对主题的访问：(但在相同的cmd-控制台中)
docker exec kafka1 kafka-topics --bootstrap-
浏览 6提问于2022-11-06得票数 0
我下载了kafka_2.12-2.1.0并放在文件夹路径"C:\kafka_2.12-2.1.0“中。为了启动kafka动物园管理员，我在命令提示符中执行了以下命令，
C:\kafka_2.12-2.1.0>bin\windows\zookeeper-server-start.bat config\zookeeper.properties
我收到的错误信息如下，
命令的语法不正确。文件名、目录名或卷标签语法不正确。
我不明白我做错了什么。有人能帮忙吗。我成功地启动了Linux中的动物园管理员和kafka服务器“bin/ zookeeper start.sh config/zook
浏览 0提问于2019-02-05得票数 2
1回答
我试图使用以下命令使用容器启动任务：
/bin/sh -c "export KAFKA_LISTENERS=\"PLAINTEXT://$(hostname -i):9092\" && start-kafka.sh"
但是，当容器试图启动时，我得到了这个错误，我不知道是什么导致了这个错误：
CannotStartContainerError: Error response from daemon: OCI runtime create failed: container_linux.go:348: starting container proce
浏览 0提问于2020-05-06得票数 3
回答已采纳
为了解决这个问题，我找了很多，但对我没什么用。
我正试图在我的linux机器(Mint)上安装Kafka，我已经完成了启动Kafka代理的步骤：
$ sudo /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
但我得到了一个著名的恼人错误：
Classpath is empty. Please build the project first e.g. by running './gradlew jar -PscalaVersion=2.13.6
浏览 8提问于2022-03-03得票数 0
我有下面的Docker文件，我正在尝试使用wait-for-it.sh，以便在Kafka可用之后控制中心出现
control-center:
image: confluentinc/cp-enterprise-control-center
hostname: control-center
restart: always
depends_on:
- zookeeper
- kafka
- schema_registry
- connect
command: ["./wait-for-it.sh&#
浏览 1提问于2018-02-28得票数 5
回答已采纳
2回答
码头设置-多个容器之间的联网
、、、、
在我的linux服务器上，我运行了3个映像-
( A)码头管理员和动物园管理员
version: '2'
services:
zookeeper:
image: wurstmeister/zookeeper:3.4.6
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka:2.11-2.0.0
ports:
- "9092:9092"
expose:
- "9093"
environment:
浏览 7提问于2020-01-28得票数 1
回答已采纳
我使用pykafka从kafka主题中获取消息，然后进行一些处理并更新到mongodb。因为pymongodb每次只能更新一项，所以我启动了100个进程。但在启动时，一些进程出现错误"PartitionOwnedError和ConsumerStoppedException“。我也不知道原因。谢谢。
kafka_cfg = conf['kafka']
kafka_client = KafkaClient(kafka_cfg['broker_list'])
topic = kafka_client.topics
浏览 5提问于2016-09-21得票数 3
1回答
Kafka和IIDR CDC
、、、、
我正在尝试使用：DB2--IBM -Kafka来构建CDC管道，并试图找到正确的方法来设置这个管道。我试过在下面-
1.在prem上的linux上安装一个3节点kafka集群
2.使用- setup-iidr-11.4.0.1-5085-linux-x86.bin文件在linux上安装IIDR软件。CDC实例已经启动并运行。
各种在线文档建议安装“IIDR管理控制台”来配置源数据存储和CDC服务器配置，并配置Kafka订阅配置来构建管道。
目前，我没有安装管理控制台。很少有人问这个问题-
1.在设置kafka-CDC管道时，是否有任何替代IBM管理控制台的方法？
2.如何获得IIDR管理控制台
浏览 2提问于2018-11-18得票数 1
回答已采纳
1回答
我正在尝试启动本地Kafka代理，但是错误显示，当尝试执行shell脚本时，权限被拒绝。当我运行docker compose -f docker-compose.dev.yml up时，我会看到以下错误Error response from daemon: failed to create shim task: OCI runtime create failed: runc create failed: unable to start container process: exec: "./create-kafka-topic.sh": permission denied: u
浏览 35提问于2022-07-22得票数 0
2回答
我试图为Kafka添加新的存储空间，以下是我已经完成的工作：
在Linux操作系统下添加、准备和挂载存储
在Kafka Broker中添加新存储: log.dirs: /data1 0/kafka-log，/data1 1/kafka-log
重新启动卡夫卡经纪人
已经创建了/data1 1/kafka-log下的新目录，但大小为：
du -csh /data1 1/kafka-log/156 k/data1 1/kafka-log/
而且它的尺寸不仅在增长，而且只使用旧的/data0。
我错过了什么？要解决这个问题，我还应该做些什么呢？存储空间几乎已满，/data1仍
浏览 1提问于2016-06-09得票数 1
回答已采纳
我有以下文件，producer.js，摘自。
const { Kafka } = require('kafkajs')
const kafka = new Kafka({
clientId: 'my-app',
brokers: ['broker:9092'],
})
const producer = kafka.producer()
const main = async () => {
await producer.connect()
await producer.send({
topic: &#
浏览 17提问于2022-07-13得票数 0
Bluemix MessageHub文档将python用户指向汇合的kafka库：
所以我试着安装：
!pip install --user confluent-kafka
但是，我碰到了这个错误：
Collecting confluent-kafka
Using cached confluent-kafka-0.9.1.2.tar.gz
Installing collected packages: confluent-kafka
Running setup.py install for confluent-kafka ... - \ error
Complete o
浏览 4提问于2016-10-30得票数 0
回答已采纳
我使用bitnami/kafka docker模板创建了一个kafka设置。在多次重新创建容器(我无法连接到9092上的Kafka )之后，我终于启动并运行了我的集群。我认为这些问题是由于Docker安装在Windows上而不是Linux上的事实造成的。 我目前的问题是，我无法使用kafka-python库和以下代码来使用任何消息： from kafka import KafkaConsumer
from kafka import TopicPartition
print('Making connection.')
consumer = KafkaConsumer(boot
浏览 48提问于2020-01-19得票数 2
2回答
我想知道是否有可能读取和处理多个消息由Kafka消费者(Java客户端)并行..I意味着使用多线程...我应该使用rxJava吗?？
1)这是一个好的方法吗? 2)而且根据我的理解，Kafka甚至将每个线程都视为consumer...please，如果我错了，请纠正我……
3)并希望使Java客户端作为守护服务运行在Linux中，这样它就可以连续运行，轮询Kafka的消息，读取和处理相同的..is这是一个很好的方法。
浏览 0提问于2016-02-24得票数 0
对不起，我正在绞尽脑汁想弄清楚这件事。我的kafka代理说正在等待连接到zookeper，然后关机(超时)，.I检查了代理的配置/端口，做了netstat等也确认了zookeper的设置。但是，如果我重新启动我的ubuntu内核(运行kafka broker的地方)，一切都是正常的。Zookeeper在Linux mint上。请告诉我哪些日志文件可以给我更多的细节-我做了通常的netstat和lsof没有运气。
浏览 0提问于2021-03-19得票数 0
我试图连接卡夫卡-用localhost:3030连接到本地的mssql，当我尝试为mssql建立一个新的连接时，我会收到这个错误。在centos 7(linux)中。Mssql数据来自外部IP(windows)，我的使用者在linux环境中。
“没有找到适合配置的驱动程序”。
connect-distributed.properties如下所示；
plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors,
我在/opt/connectors/kafka-connect-jdbc/下添
浏览 3提问于2019-12-05得票数 1
我有一个关于kafka升级的新手问题..这是我第一次在Linux上升级我的kafka。
我现在的版本是"kafka_2.11-1.0.0.tgz"..当我最初安装的时候，我有一个名为kafka_2.11-1.0.0的文件夹。
现在我下载了一个新版本"kafka_2.12-2.3.0.tgz“。如果我解压缩，它将创建一个新的文件夹kafka_2.12-2.3.0，这将导致2个独立的kafka与server.properties。
根据文档，我必须使用以下2个属性更新server.properties。
inter.broker.protocol.version=2.3 l
浏览 44提问于2019-08-06得票数 1
回答已采纳
我想杀死我的Kafka Connect分布式工作进程，但我无法(或者我不知道如何)确定在linux中运行的哪个进程是该工作进程。 运行时 ps aux | grep worker 我确实看到了很多工作进程，但不确定哪些是连接工作进程，哪些是标准的非连接工作进程 诚然，昨天只启动了其中一个进程，我怀疑就是这个进程，但这显然不是所有情况下的充分条件，例如，如果Kafka集群昨天上线。那么，一般来说，我如何确定哪个进程是Kafka连接工作进程？ 这里证明愚蠢的方法是什么？
浏览 60提问于2019-04-26得票数 2
回答已采纳
我正在尝试从主分支构建Openssl-3.0.0，以便在Ubuntu 16上使用ktls功能，但是构建跳过了ktls功能。
尽管我使用的是Ubuntu16.04.1(内核版本: 4.15)，但不知怎么的，这个构建正在获取主机中不存在的旧版本的内核头，并且跳过了KTLS特性，
我是不是漏掉了什么？有人能帮我建造这个组件吗？
以下是步骤
步骤1:验证标头
kafka-secure2:/usr/src$ uname -a
Linux kafka-secure2 4.15.0-50-generic #54~16.04.1-Ubuntu SMP Wed May 8 15:55:19 UTC 2019 x
浏览 0提问于2019-06-28得票数 -1
我们使用AWS Fargate容器运行Kafka流，并在启动应用程序时获得以下错误。我怎么才能避免这种情况？
Exception in thread java.lang.UnsatisfiedLinkError: /tmp/librocksdbjni3589189542893555938.so: Error loading shared library ld-linux-x86-64.so.2:
No such file or directory (needed by /tmp/librocksdbjni3589189542893555938.so)
浏览 1提问于2018-11-01得票数 1
回答已采纳
1回答
我有一个卡夫卡连接罐，需要作为码头集装箱运行。我需要捕获容器中的一个日志文件上的所有连接日志(最好是在目录/ file -/etc/kafka/kafka- connect日志中)，这些日志稍后可以使用端口中的卷被推送到本地主机(在本地主机上运行对接引擎)。当我将我的connect-log4j.properties更改为附加到日志文件中时，我看到没有创建日志文件。如果我尝试不使用docker，并通过更改connect-log4j.properties将日志写入日志文件在本地linux上运行kafka，那么它可以很好地工作，但不会从docker运行。任何建议都会很有帮助。
Docker File
浏览 4提问于2017-09-26得票数 2
回答已采纳
我在vm中设置了kafka集群。
但我有个问题。
我的kafka版本是kafka 2.11-0.0.0
$ bin/kafka-server-start.sh config/zookeeper.properties
[2017-01-31 09:15:55,216] FATAL (kafka.Kafka$)
org.apache.kafka.common.config.ConfigException: Missing required configuration "zookeeper.connect" which has no default value.
at
浏览 35提问于2017-01-31得票数 8
3回答
我试过以下方法-
./confluent start给-
此CLI仅用于开发，而不是用于生产。
使用CONFLUENT_CURRENT: /tmp/confluent.w1S9B10m启动动物园管理员
动物园管理员要开始卡夫卡了
卡夫卡起来了
启动模式-注册表模式-注册表已启动
开始卡夫卡休息
卡夫卡-休息起来了
起动连接
连接已启动ksql-server。
ksql server启动
之后，./kafka-topics --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic u
浏览 0提问于2018-10-02得票数 0
回答已采纳
我试图设置我的项目，并尝试构建或尝试运行，但每次它显示这个错误，未定义的引用。到目前为止，我所了解到的代码还不能读取librdkafka的文件。
我试图更改安装这些工具或库的位置，试图更改它们的版本，但没有成功地解决它。
这些是安装库的位置。
/opt/apache-zookeeper-3.5.5-bin
/opt/zookeeper
/home/harishrana/go/src/github.com/confluentinc/confluent-kafka-go
/home/harishrana/librdkafka
这就是我的项目所在的位置。
/home/harishrana/go/s
浏览 5提问于2019-09-24得票数 2
回答已采纳
如果我有三个经纪人运行在卡夫卡集群，其中一个失败了，因为一个错误。所以我只剩下两个经纪人了。
( 1)通常情况下，当这种情况发生时，重新启动失败的代理将解决问题？2)如果重新启动代理无法解决问题，我可以删除失败代理拥有的所有数据并重新启动吗？(因为其他两个经纪人将恢复所有数据)。这种方法在生产中可以吗？如果没有，为什么？
很久以前，当我在Windows 10上用我的桌面测试Kafka时，如果代理出现错误而服务器重新启动无法工作，我会删除所有数据。然后，它开始正常运行。(我知道卡夫卡和Windows的问题。)因此，我很好奇这是否适用于多集群Kafka (Linux)环境。
浏览 3提问于2019-11-26得票数 0
回答已采纳
1回答
忽略librd中的测试
、、、
我的golang项目依赖于librd kafka 当我尝试从我的jenkin运行go vet ./...或go test ./...时，我得到了以下错误。我相信这是因为我运行的是./...，但即使我不得不忽略供应商，我也不确定应该是什么，我尝试了go test $(go list ./... | grep -v /vendor/librdkafka)，但它没有帮助。 /usr/lib/gcc/x86_64-alpine-linux-musl/9.3.0/../../../../x86_64-alpine-linux-musl/bin/ld: /go/pkg/mod/gopkg.in/conf
浏览 62提问于2020-08-26得票数 3
我在网上找不到这样一个特别的命令，所以我恳请你帮忙:)
上下文
通过使用podTemplate方法，我用几个容器定义了一个containerTemplate：
ubuntu:trusty (14.04 LTS)
postgres:9.6
最后，wurstmeister/kafka:latest
在管道中执行一些Groovy编码时，我将几个依赖项安装到我的ubuntu:trusty容器中，比如最新的Git、Golang1.9等等，并且我还从Github签出了我的项目。
在处理完所有这些依赖之后，我设法编译、运行迁移(这意味着Postgres已经启动并运行，并且我的应用程序连接
浏览 0提问于2018-03-26得票数 0
我只是用buildx制作了multarch图像
运行docker buildx build --platform linux/amd64,linux/arm64 -t maskertim/zookeeper-demo .时
错误消息
错误如下：
------
> [linux/arm64 3/5] RUN curl "https://archive.apache.org/dist/kafka/2.8.0/kafka_2.13-2.8.0.tgz" -o /tmp/kafka/kafka.tgz && mkdir /kafka &&
浏览 12提问于2021-09-21得票数 7
ApacheKafka3.0昨天发布了，我决定在Windows 10上试用它。尽管ZooKeeper一开始很完美，但是卡夫卡在记录了很少的异常后关闭了。
我知道AccessDeniedException很容易解释，但是权限不是问题，因为Kafka能够创建AccessDeniedException所记录的文件。
[2021-09-22 23:58:18,295] ERROR Failed to write meta.properties due to (kafka.server.BrokerMetadataCheckpoint)
java.nio.file.AccessDeniedExcepti
浏览 3提问于2021-09-22得票数 10
2回答
如何从Linux上的文件中删除最后一个逗号分隔符？
文件示例：
"is_supported_kafka_ranger" : "true",
"kafka_log_dir" : "/var/log/kafka",
"kafka_pid_dir" : "/var/run/kafka",
"kafka_user" : "kafka",
"kafka_user_nofile_limit" : "128000",
"kafka_user_
浏览 0提问于2018-06-03得票数 9
回答已采纳
在远程节点上部署了一些Apache Kafka实例后，我观察到Kafka存档中的kafka-server-stop.sh脚本出现了问题。
默认情况下，它包含：
#!/bin/sh
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
浏览 2提问于2014-08-29得票数 18
我们使用的是卡夫卡版本- 2.7.1。集群包括LinuxRHEL7.6版本上的5台Kafka机器
我们希望对所有5个代理执行Kafka重新启动，但是由于Kafka集群是生产集群，那么滚动重新启动应该是正确的方法。
因此，我们编写了bash脚本，执行以下操作
command)verify 停止kafka01 broker (由systemctl systemctl no Kafka PID kafka01 kafka01 broker确认kafka01正在监听卡夫卡端口6667 )
并在kafka02、kafka03、kafka04、kafka05上继续执行相同的步骤1-4，再加上上述步骤1-4
浏览 0提问于2021-06-22得票数 2
回答已采纳
我刚刚开始学习Kafka/Zookeper。我面临的问题是，当我尝试运行控制台使用者来验证主题的消息时，我得到了以下错误-
vagrant@debian-70rc1-x64-vbox4210:~$ $KAFKA_HOME/bin/kafka-console-consumer.sh --zookeeper 192.168.33.10:2181 --topic topic-3
[2015-02-22 22:56:36,666] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2015-02-22 22:56:36,698]
浏览 0提问于2015-02-23得票数 7
1回答
当我试图构建我们的go应用程序时，我们得到了下面的错误。 => ERROR [builder 7/7] RUN CGO_ENABLED=0 GOOS=linux go build -o myapp
> [builder 7/7] RUN CGO_ENABLED=0 GOOS=linux go build -o myapp:
#14 6.962 # main
#14 6.962 ./kafkaproducer.go:12:12: undefined: kafka.NewProducer
#14 6.962 ./kafkaproducer.go:12:31: undefined:
浏览 130提问于2021-08-27得票数 2
具有多个linux和windows节点池的AKS集群。Kafka客户端: Confluent.Kafka 1.4.4
正在尝试解析名为"tt- kafka -kafka-bootstrap.shared“的kafka服务。
来自windows pod中的-无法解决：
kubectl exec -it test-print-7f6b64dc4f-4z7lt --namespace test -- nslookup tt-kafka-kafka-bootstrap.shared
Server: kube-dns.kube-system.svc.cluster.local
Address:
浏览 0提问于2020-10-29得票数 0
我运行这个命令来提取图像，启动服务。
docker-compose -f dc-all.yml up
但是，我注意到数据保存在图像中，例如，一旦我放下和向上停靠，数据库数据就消失了，我试着向下停靠的命令。
docker-compose -f dc-all.yml down
保存数据的最佳实践是什么？
或者如何在不重新启动的情况下保持码头运行？例如，windows重新启动不会
样本yml文件
networks:
test:
services:
db:
networks:
- pm
image: microsoft/mssql-server-linux:2
浏览 3提问于2019-10-21得票数 1
回答已采纳
我正试图在库伯奈特吊舱里运行我的卡夫卡和动物园管理员。
这是我的zookeeper-service.yaml
apiVersion: v1
kind: Service
metadata:
annotations:
kompose.cmd: kompose convert
kompose.version: 1.1.0 (36652f6)
creationTimestamp: null
labels:
io.kompose.service: zookeeper-svc
name: zookeeper-svc
spec:
ports:
- name:
浏览 0提问于2018-09-03得票数 12
回答已采纳
我们正在尝试使用apache从Linux发送消息到windows；在操作系统和在各自本地主机上发生的消息传递中都配置了Zoo门将和Kafka；
从windows到Linux消息传递时出错；
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException:错误-当向主题my_topic发送消息时出现错误，键为null，值:5个字节带有错误: 60000 ms后元数据中不存在主题my_topic。2020-10-09 11:24:22
浏览 3提问于2020-10-12得票数 0
我在go二进制文件中使用confluent-kafka-go库，这个库需要链接到librdkafka。我的项目中的其他目标使用librdkakfa，所以我使用rules_foreign_cc的cmake_external规则生成了静态的librdkafka.a和librdkafka++.a： //this is my "third_party/kafka/BUILD" file:
load("@rules_foreign_cc//tools/build_defs:cmake.bzl", "cmake_external")
cm
浏览 14提问于2019-04-16得票数 6
回答已采纳
全新服务器，全新安装confluent-community-2.12版本5.3.1。
使用/etc/schema-registry/schema-registry.properties配置模式注册表，其中包含(我将ips +主机名匿名)：
# fyi, kafkastore.connection.url is not specified
listeners=http://0.0.0.0:8081
kafkastore.bootstrap.servers=PLAINTEXT://kafka-broker-xxx-1:9092,PLAINTEXT://kafka-broker-xxx-2:9092
浏览 64提问于2019-11-07得票数 0
回答已采纳
当我启动Kafka服务器时，Zookeper已经启动并在windows env.Now中运行。
.\bin\windows\kafka-server-start.bat .\config\server.properties
未显示任何内容
G:\Apache Kafka\kafka_2.11-0.11.0.0\kafka_2.11-0.11.0.0>.\bin\windows\kafka-serv
er-start.bat .\config\server.properties
G:\Apache Kafka\kafka_2.11-0.11.0.0\kafka_2.11-0.11.0.0
浏览 0提问于2017-08-06得票数 1
1回答
以下文件夹-> /var/run/kafka，包括kafka服务的PID号
示例
ls -ltr /var/run/kafka/kafka.pid
-rw-r--r-- 1 kafka hadoop 7 Nov 10 14:14 /var/run/kafka/kafka.pid
当我们重新启动卡夫卡7卡夫卡机器和机器时
我们注意到-> /var/run/kafka文件夹是不存在的
因此，卡夫卡服务无法启动。
经过简短的回顾，我们可以看到/run属于tmpfs文件系统，如下所示
df -h | grep tmpfs
devtmpfs 63G
浏览 0提问于2021-05-04得票数 0
回答已采纳
我试图在windows 10上安装Kafka docker映像，但它总是说“映像操作系统”linux不能在这个平台上使用“。
注:我处于"Windows容器模式“。
虽然，如果我更改对接设置“切换到Linux容器”，那么码头上有各种图像，如spotify/kafka，wurstmeister/kafka，我可以安装这些图像。
问:我们是否有卡夫卡在码头集线器的形象，可以安装在windows上，而在Winodws容器模式下？
浏览 2提问于2018-10-15得票数 4
回答已采纳
2回答
我不能用GCE创造卡夫卡的主题
在GEC
The programs included with the Debian GNU/Linux system are free software;
the exact distribution terms for each program are described in the
individual files in /usr/share/doc/*/copyright.
Debian GNU/Linux comes with ABSOLUTELY NO WARRANTY, to the extent
permitted by applicable
浏览 0提问于2019-07-13得票数 0
1.我的版本信息
jdk-8u191-linux-x64.tar.gz
kibana-6.5.0-linux-x86_64.tar.gz
elasticsearch-6.5.0.tar.gz
logstash-6.5.0.tar.gz
filebeat-6.5.0-linux-x86_64.tar.gz
kafka_2.11-2.1.0.tgz
zookeeper-3.4.12.tar.gz
2.问题描述
我有一个XML格式的日志文件。我用文件拍收集这个文件，并把它推到卡夫卡内容混淆。
这是我的文件节拍配置
filebeat.inputs:
- type: log
enabled: t
浏览 1提问于2019-02-15得票数 0
回答已采纳
我已经用kafka生成了一个jhipster应用程序。我使用docker-组合启动了kafka.yml，当我启动应用程序时，会出现以下错误
org.springframework.context.ApplicationContextException:未能启动bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'；嵌套异常在获取主题元数据时org.apache.kafka.common.errors.TimeoutException:超时过期
kafka.yml
vers
浏览 2提问于2019-08-04得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
