直接在zookeeper/Kafka上创建SCRAM凭据
在云计算领域，ZooKeeper和Kafka是两个常用的开源软件，用于分布式系统的协调和消息传递。SCRAM（Salted Challenge Response Authentication Mechanism）是一种安全认证机制，用于在分布式系统中进行身份验证。
- ZooKeeper：
- 概念：ZooKeeper是一个分布式的开源协调服务，用于维护和管理分布式系统中的配置信息、命名服务、分布式锁等。
- 优势：高可用性、一致性、可靠性、容错性，提供简单的API和丰富的特性。
- 应用场景：分布式系统的配置管理、命名服务、分布式锁、领导者选举等。
- 腾讯云相关产品：腾讯云分布式协调服务 TDSKF（Tencent Distributed Service for Kafka），详情请参考：TDSKF产品介绍
- Kafka：
- 概念：Kafka是一个分布式的开源消息队列系统，用于高吞吐量的发布和订阅消息流。
- 优势：高吞吐量、可持久化、可扩展性、容错性，支持水平扩展和消息的持久化存储。
- 应用场景：日志收集、流式处理、事件驱动架构、消息队列等。
- 腾讯云相关产品：腾讯云消息队列 CKafka，详情请参考：CKafka产品介绍
- SCRAM凭据：
- 概念：SCRAM凭据是一种安全认证机制，用于在分布式系统中进行身份验证和授权。
- 分类：SCRAM凭据分为客户端凭据和服务端凭据，用于验证客户端和服务端之间的身份。
- 优势：提供更强的安全性和防护能力，减少密码泄露和暴力破解的风险。
- 应用场景：分布式系统中的用户身份验证和授权。
- 腾讯云相关产品：腾讯云访问管理 CAM，详情请参考：CAM产品介绍
综上所述，ZooKeeper和Kafka是云计算领域常用的开源软件，SCRAM凭据是一种安全认证机制，用于分布式系统中的身份验证。在腾讯云中，可以使用TDSKF进行分布式协调服务，使用CKafka进行消息队列服务，使用CAM进行访问管理和身份验证。
相关·内容
通常，kafka-configs.sh用于创建SCRAM凭据，以便使用以下命令进行身份验证
> bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=alice-secret],SCRAM-SHA-512=[password=alice-secret]' --entity-type users --entity-name alice
有没有其他方法可以直接在zookeeper上或通过Java创建这些凭据？
浏览 1提问于2017-08-09得票数 0
我试图将安全性添加到kafka集群中，然后跟踪文档：
我使用以下方法添加用户：
kafka-configs.sh --zookeeper zookeeper1:2181 --alter --add-config 'SCRAM-SHA-256=[password=admin-secret],SCRAM-SHA-512=[password=admin-secret]' --entity-type users --entity-name admin
我修改server.properties：
broker.id=1
listeners=SASL_PLAINTEXT://kafka1
浏览 31提问于2020-05-04得票数 2
回答已采纳
Kafka SSL对等端没有进行身份验证，而是返回匿名错误，当客户端连接代理SASL端口时，它允许在明文或SSL端口上进行连接。
在启用SSL的windows系统中，我有kafka 2.2.0，其中kafka broker明文在9092上运行，SSL在9093上运行。在此基础上，将SASL配置为SCRAM机制，监听器端口为9094，在以kafka-console- producer -broker-list localhost:9094 --topic xxx运行生产者时，出现了问题摘要中提到的错误。
下面是SSL配置，没有提供其他配置，比如basic和SSL
zookeeper.proper
浏览 2提问于2019-10-11得票数 0
1回答
我想在Kafka中配置SASL/SCRAM。我在幻灯片共享中找到了这个资源，在创建用户时，我得到了以下错误。
Error while executing config command requirement failed: Invalid
entity config: all configs to be added must be in the format
"key=val".
java.lang.IllegalArgumentException: requirement failed: Invalid entity config: all configs to be ad
浏览 0提问于2018-01-04得票数 0
回答已采纳
我在启动kafka服务器时遇到错误，我已经设置了SSL，它在kafka 3代理上运行良好。并且zookeeper也是用SSL设置的 现在尝试从服务器属性文件中为kafka broker设置SASL_SSL的SCRAM。 它不工作，我用下面的命令创建了一个用户 kafka-configs.sh --zookeeper localhost:2182 --zk-tls-config-file zookeeper-client.properties --entity-type users --entity-name broker-admin --alter --add-config 'SCR
浏览 112提问于2021-10-05得票数 1
我使用的是Publish Kafka处理器的下一个配置：
编辑kafka和zookeeper配置：
zookeeper.properties
authProvider.sasl=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
requireClientAuthScheme=sasl
jaasLoginRenew=3600000
zookeeper_jaas.conf
Server {
org.apache.zookeeper.server.auth.DigestLoginModule required
us
浏览 3提问于2021-01-14得票数 1
我正在尝试建立我的第一个卡夫卡集群使用汇合6.0.1社区版。我有三个动物园管理员和三个卡夫卡节点。三个服务器节点是：
kafkaserver1kafkaserver2kafkaserver3
每个节点运行动物园管理员和kafka服务。身份验证是:使用SCRAM-SHA-256的SASL_SSL。
动物园管理员和kafka服务似乎都很好，但是当我试图分配ACL时，我得到了以下错误：
Error while executing ACL command: KeeperErrorCode = NoAuth for /kafka-acl/TransactionalId
org.apache.zookee
浏览 4提问于2021-01-14得票数 1
我想使用两个侦听器配置Kafka身份验证(现在只需要身份验证，不需要加密)：
，用于代理与明文安全的私有通信，，用于消费者/生产者，与SASL_PLAINTEXT和SCRAM-SHA-256的公共通信。
我有一个Kafka集群，只有一个代理(用于测试)，还有一个带有两个节点的动物园管理员集群
我所做的步骤是：
在动物园管理员上创建'admin‘和'test-user’用户。
kafka-configs.sh --zookeeper zk:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=
浏览 6提问于2020-11-06得票数 0
我一直试图添加一个SASL认证到我的卡夫卡经纪人使用SASL_PLAINTEXT SCRAM-SHA-256一段时间，但没有任何成功。我一直在卡夫卡的日志文件上发现以下错误。
错误控制器id=0，targetBrokerId=0连接到节点0的身份验证失败，原因是:由于SASL机制SCRAM-SHA-256 (org.apache.kafka.clients.NetworkClient)的凭据无效，身份验证失败。
但是我一直在跟踪卡夫卡在SCRAM Config上的文档，并且没有成功地实现这一目标。
我使用kafka-configs.sh注册了一个管理员用户，如下所示：
bin/kafk
浏览 3提问于2018-06-04得票数 8
在实现代理到动物园管理员身份验证时，我在broker 2节点上得到了下面的异常
在SSL设置中，群集配置为SSL身份验证。
Broker 1成功地连接到动物园管理员，但是在broker 2上有一个异常org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /broker/ is
同时，当我停止broker 1并将broker 2连接到动物园管理员时，连接正在工作。问题是一个卡夫卡只与动物园管理员相连，另一个卡夫卡却没有同时连接。
节点1: kafka1和动物园管理员节点2: kafka
浏览 5提问于2021-05-13得票数 1
我尝试过kafka身份验证SASL_PLAINTEXT / SCRAM，但是身份验证在春季启动时失败了。
我试着改变SASL_PLAINTEXT /平原，它是有效的。但是SCRAM是身份验证失败的SHA-512和SHA-256
做了很多不同的事情，但没有用.我怎么才能修好它？
经纪人日志
broker1 | [2020-12-31 02:57:37,831] INFO [SocketServer brokerId=1] Failed authentication with /172.29.0.1 (Authentication failed during authenticatio
浏览 0提问于2020-12-31得票数 1
回答已采纳
我想要向我的kafka集群添加新用户，方法似乎是在zookeeper数据库中添加SCRAM-SHA-512/256配置，但我只知道如何使用命令行工具来完成此操作，如下所示：
bin/kafka-configs.sh --zookeeper zookeeper_server_address --alter --add-config "SCRAM-SHA-512=[password=password]" --entity-type users --entity-name userName
有没有其他方法可以使用Kafka API for Java来实现这一点？
浏览 0提问于2020-05-05得票数 0
我在窗户上运行卡夫卡。我正在尝试设置SASL/SCRAM身份验证。是我用来设置SASL/SCRAM的链接。在运行bin/kafka-configs --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=alice-secret],SCRAM-SHA-512=[password=alice-secret]' --entity-type users --entity-name alice时，我得到了错误
未知动态配置: Set('SCRAM-SHA-
浏览 7提问于2020-09-23得票数 2
我正在尝试设置我的kafka集群以接受SASL_SSL / SCRAM身份验证。首先，一切都在正常工作，客户端使用SASL_SSL / GSSAPI进行连接。我的Zk服务器也被配置为SASL身份验证和TLS。
我使用的是卡夫卡和Zk的合流对接图像：
汇合点/cp-kafka:6.0.1
汇合部/cp-动物园管理员:5.5.3-3
因此，我只是修改了我的设置，允许SCRAM-SHA-512在Kafka：KAFKA_SASL_ENABLED_MECHANISMS=GSSAPI,SCRAM-SHA-512中使用。
在之后，我现在想在Zk中添加用户，这就是问题的起点(从Kafka节点)
浏览 17提问于2021-01-21得票数 2
我们有一个kafka集群，并且正在根据这些标准锁定特定的节点：。
一旦我们用SASL:kafka:cdrwa锁定了/broker/topics节点，我们就无法使用kafka-topics.sh工具来创建主题。我们尝试在代理上使用这些工具，它在jaas文件中有正确的KafkaClient，但似乎动物园管理员将cmd工具视为单独的客户机。当我们锁定/kafka并使用kafka-acls.sh工具时，我们正在经历同样的事情。
我们如何在命令行工具中传递jaas文件？
这里更新的是jaas文件的内容(密码已删除)。工具和代理都存在于同一台机器上。经纪人没有与动物园管理员认证的问题。
KafkaServ
浏览 0提问于2019-08-13得票数 2
回答已采纳
我们正在使用SASL scram，用户和密码被创建并存储在我们的动物园管理员实例中。我们可以获得具有散列密码的用户列表。
kafka-configs --describe --zookeeper <zookeeperurl> --entity-type users
我想把这些用户和密码移到另一个动物园管理员的实例上。是否有一种方法可以转换它们，甚至获得纯文本密码，以便在另一个实例上重新创建它们？
谢谢
浏览 2提问于2019-11-27得票数 0
回答已采纳
摘要
主要的问题是如何确保在卡夫卡上设置ACL。ACL可以用于限制谁可以消费/生产主题，但是ACL的设置是如何限制的？例如，使用kafka-acls.sh的另一台网络机器上的一些用户
详细信息
我对kafka非常陌生，我刚刚设置了我的第一个kafka 1.0.0集群，我使用Kafka管理CLI(kafka-acls.sh)为主体授予acls。
这是我发现的问题:我可以在任何其他机器上使用这个kafka-acls.sh来操纵我的kafka集群，而不需要任何许可？！这是一个现存的安全问题吗？
我的要求是，作为一个管理员，对于我的卡夫卡主题，我会授予消费者阅读许可。但如果消费者能够使用kafka-a
浏览 2提问于2018-01-07得票数 2
回答已采纳
1回答
Kafka已经提供了不同的SASL认证机制，如GSSAPI (Kerberos)、PLAIN、SCRAM-SHA-256、SCRAM-SHA-512和OAUTHBEARER。
对于生产环境，上述列表中的最佳身份验证机制是什么？
浏览 11提问于2018-09-26得票数 3
在我开始告诉您之前，我对cloudformation和编码的整个过程非常陌生。
我一直在尝试编写一个云形成模板，以启动一个具有单一动物园节点的实例，并逐步执行。所以我写了我的用户数据来下载Kafka tar并解压缩它。
现在，我不想使用“bin/zooKeer-server-start.sh -daemon config/zookeeper.properties”来启动动物园管理员，而是要创建一个名为zookeeper的文件，然后在其上编写一个shell脚本，并使其可执行--如何在cloudformation中执行呢？
DAEMON_PATH=/home/ubuntu/kafka/bin
浏览 3提问于2020-10-24得票数 1
回答已采纳
我主持卡夫卡在码头在Windows。使用对接图像。Kafka数据存储在本地Windows文件夹中，以便持久化。Windows文件夹通过docker卷映射到Kafka码头图像。我可以创建主题、发布和使用消息。但是，当我尝试删除主题时，我会收到以下错误：
Error while deleting test-0 in dir /var/lib/kafka. (kafka.server.LogDirFailureChannel)
java.io.IOException: Failed to rename log directory from /var/lib/kafka/test-0 to /va
浏览 14提问于2018-01-05得票数 11
回答已采纳
我试图建立一个卡夫卡集群与3个经纪人在码头。
问题是:当我执行一个操作(即创建/列表/删除主题)时，总是有一个代理连接失败并重新启动Docker容器。此问题不会发生在2或单个代理的集群上。
我的复制步骤是：
Run docker-编写由一个卡夫卡容器组成的Open并创建一个主题--这个，一个随机代理被断开并从集群中删除。有时，上述执行的响应是指出复制因子不能大于2的错误(因为1个代理已从集群中删除)。
我是卡夫卡的新手。我想我只是有一些愚蠢的错误，但我不知道是什么。我在文档中搜索，但还没有找到。
这是我的停靠-撰写文件：
version: "3.9"
networks:
浏览 5提问于2022-01-17得票数 0
我已经设置了一个带有安全性的Kafka集群，它工作得很好。
根据文档，我已经使用命令kafka-configs.sh创建了用户名和密码，并授予该用户对主题的访问权限。
这也很好用。
但是，kafka-configs.sh命令本身不需要任何类型的身份验证，所以我认为任何人都可以运行该命令，在Kafka中创建自己的用户并授予自己的权限。
也许我需要在Zookeeper上启用SASL安全？但我找不到任何关于如何做到这一点的一致或有效的文档。像requireclientauthscheme=sasl这样向zookeeper.config添加属性似乎没有任何作用。或者至少它不会阻止kafka-confi
浏览 9提问于2018-01-09得票数 2
我正在Docker上创建一个3节点Zookeeper和3节点Kafka集群。我需要将Kafka集群链接到Zookeeper集群。
下面是docker-compose.yml代码-
version: '2'
services:
zookeeper-1:
image: zookeeper:latest
environment:
ZOOKEEPER_SERVER_ID: 1
ZOOKEEPER_CLIENT_PORT: 22181
ZOOKEEPER_TICK_TIME: 2000
ZOOKEEPER_INIT_LI
浏览 49提问于2018-02-14得票数 1
1回答
我试图在Minikube上设置Kafka，这是一个非常基本的设置。我无法验证由于kafkacat失败，卡夫卡和动物园管理员的设置是否正确。
这是我的配置：
动物园管理员
kind: Deployment
apiVersion: apps/v1
metadata:
name: zookeeper-deployment-1
spec:
selector:
matchLabels:
app: zookeeper-1
template:
metadata:
labels:
app: zookeeper-1
spec:
浏览 6提问于2020-07-31得票数 0
我一直在尝试在Docker容器上运行Zookeeper和Kafka。在我的终端中，我收到了很多[error occurred during error reporting , id 0xb]和[Too many errors, abort]错误。然后是library initialization failed - unable to allocate file descriptor table - out of memory。 我使用以下docker-compose.yml文件 version: "3.8"
services:
zookeeper:
image:
浏览 2275提问于2021-08-13得票数 0
2回答
我在远程Ubuntu服务器上安装了一个Apache (v.2.13-3.0.0)。我遵循本教程来保护我的集群：
但是，当我尝试用jaas文件启动Kafka时，命令如下：
export KAFKA_OPTS=-Djava.security.auth.login.config=<kafka-binary-
dir>/config/kafka_server_jaas.conf
./bin/kafka-server-start.sh ./config/server.properties
我收到错误：
[2021-11-12 10:30:47,864] INFO Registered k
浏览 2提问于2021-11-12得票数 3
我试图在Kubernetes中设置一个Kafka pod，但是我一直收到这个错误：
[2020-08-30 11:23:39,354] ERROR [KafkaApi-0] Number of alive brokers '0' does not meet the required replication factor '1' for the offsets topic (configured via 'offsets.topic.replication.factor'). This error can be ignored if the clu
浏览 0提问于2020-08-30得票数 0
我们有不同的消费者组，他们使用来自不同topics.We的数据，topic.We的不同分区需要允许一些消费者组访问特定的主题，以便只有这些组可以从主题中读取。我尝试了像这样的融合Kafka访问控制列表：
bin/kafka-acls.sh --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:Bob --consumer --topic test-topic --co
浏览 9提问于2017-07-12得票数 1
目前在将Kafka部署到机器上后，需要运行以下命令才能正确配置：
docker run --net=azure-iot-edge --rm confluentinc/cp-kafka:5.1.2 kafka-topics --list --zookeeper zookeeper:2181
docker run --net=azure-iot-edge --rm confluentinc/cp-kafka:5.1.2 kafka-topics --create --topic new-project --zookeeper zookeeper:2181 --partitions 3 --repl
浏览 1提问于2019-10-16得票数 1
2回答
必须从Dockerizing应用程序中与Kafka进行通信，我能够得到工作的唯一选择就是Dockerized。
这是我的docker-compose-yml
version: '3.5'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
networks:
- kafka-network
kafka:
image: wurstmeister/kafka
ports:
- "909
浏览 0提问于2018-12-10得票数 5
回答已采纳
我有一个Spring Boot (2.3.3)服务，它使用spring-kafka来访问专用的Kafka/Zookeeper配置。我一直在使用服务器设置spring.kafka.bootstrap- application.properties =localhost:9092来访问我的开发/测试Apache Kafka服务。 然而，在生产中，我们在Zookeeper中配置了一个Kafka Brokers集群(在许多服务器上)，并且我被要求修改我的服务来查询Zookeeper，以获得代理列表并使用该列表而不是引导服务器配置。原因是，众所周知，我们的DevOps人员会重新配置服务器/节点和Kaf
浏览 25提问于2020-09-15得票数 1
2回答
我正在尝试连接到amazon托管的流媒体kafka集群。我一直在学习创建主题https://docs.aws.amazon.com/msk/latest/developerguide/create-topic.html的教程。 我的VPC安全组允许此集群的所有流量进出，因此我不怀疑这会阻止连接。 我已经尝试过这个命令。 bin/kafka-topics.sh --create --zookeeper ZookeeperConnectString --replication-factor 3 --partitions 1 --topic AWSKafkaTutorialTopic 这会产生令人
浏览 30提问于2019-04-17得票数 2
当尝试使用--bootstrap-server，创建主题时，我得到了异常“执行主题命令时的错误:超时等待节点”:-
kafka-topics --bootstrap-server localhost:9092 --topic boottopic --replication-factor 3 --partitions
但是，以下工作正常，使用--动物园管理员 :-
kafka-topics --zookeeper localhost:2181--topic boottopic --replication-factor 3 --partitions
我使用的是Kafka版本2.5，而且据了解，由于
浏览 4提问于2020-05-07得票数 0
我有一个卡夫卡ProducerService，它看起来像这样：
@Injectable()
export class ProducerService implements OnModuleInit, OnApplicationShutdown {
private logger = new Logger(ProducerService.name);
public readonly topic: string;
private readonly url: string;
private readonly clientId: string;
private readonly sc
浏览 13提问于2022-04-04得票数 0
我正在尝试为Kafka更改数据捕获设置一个Docker文件环境，我遇到了以下错误：
打开到服务器的套接字连接0.0.0.0/0.0.0.0:2181。不会尝试使用SASL (未知错误)进行身份验证。
发生套接字错误: 0.0.0.0/0.0.0.0:2181:连接被拒绝
我一直在学习本教程，但它直接使用链接选项运行对接器命令，而不是使用docker-compose.yml文件。
我试图将这些转换为：
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka
到下面的docker-
浏览 4提问于2021-02-07得票数 4
回答已采纳
我已经分别安装了Zookeeper和Kakfa。已成功启动Zookeeper。当我尝试在windows上使用以下命令启动Kafka时，
C:\kafka_2.12-2.3.0\bin\windows>kafka-server-start.bat ../../config/server.properties
我一直在想，
\Novosoft\C2J\Bin\c2jruntime.zip was unexpected at this time.
不知道是什么原因造成的。
浏览 18提问于2019-07-08得票数 0
回答已采纳
1回答
我是卡夫卡的新手，我试着用在vps上安装我的第一个集群。但我仍然无法从本地pc (主机外)访问它。
这是我的码头作曲
version: '2'
services:
zookeeper-1:
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
ports:
- 22181:21
浏览 42提问于2022-04-13得票数 1
回答已采纳
我用jhipster创建了一个基本的应用程序，并添加了Apache Kafka。即使使用另一种解决方案(从我的应用程序到适用于kafka的php客户端)，我也没有任何生产和消费问题。现在，我想在集群上创建多个代理，但要从java而不是.sh文件创建。
我知道集群是使用server.properties文件设置的，其中隐含了代理的id、日志目录和其他内容。但是在我的jhipster应用程序中，代理id是在kafka.yml中声明的，所以我猜我必须编辑.yml文件来声明另一个代理。
version: '2'
services:
zookeeper:
image: con
浏览 1提问于2019-07-22得票数 2
1回答
Detail: Kafka，Cassandra和Spark，使用wurstmeister/kafka，strapdata/elassandra和bde2020/spark-master图像进行对接-合成.
我们要做的是使用连接器连接以下内容：
卡夫卡流到火花流
火花流到卡桑德拉
卡夫卡流到卡桑德拉
问题是，我们不知道它是否正常工作，因为这些技术对我们来说听起来是新的。
图形表示：
重要文件：
docker-compose.yml
version: '2'
services:
spark:
container_name: spar
浏览 1提问于2019-07-07得票数 1
1回答
我正在我的mac机上运行一个被篡改的卡夫卡(MacOS塞拉利昂(10.12.2))，但失败了。我有DockerforMacVersion17.03.1-ce，构建c6d412e。这些是我用的图像。
我遵循官方中的建议，使用以下命令运行Zookeeper和Kafka。
docker run -d \
--net=host \
--name=zookeeper \
-e ZOOKEEPER_CLIENT_PORT=32181 \
confluentinc/cp-zookeeper:3.2.1
docker run -d \
--net=
浏览 0提问于2017-06-28得票数 0
回答已采纳
1回答
我正在创建一个3节点Zookeeper集群和一个3节点Kafka集群。当我创建Zookeeper集群时，只创建了其中一个zookeeper节点，而对于其他两个节点中的每个节点，其他两个节点退出时都会出现以下错误：
zookeeper-3_1 | 2018-02-13 17:38:22,310 [myid:] - INFO [main:ServerCnxnFactory@117] - Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory
zookeeper-3_1 | 2018
浏览 23提问于2018-02-14得票数 2
回答已采纳
我正在尝试为AWS MSK集群使用kafka rest代理。
MSK加密详细信息：
集群中的
TLS加密:启用
客户与经纪人之间的
TLS加密:启用
明文:未启用
我在MSK上创建了主题"TestTopic“，然后在与MSK相同的VPC中创建了另一个作为Rest代理的EC2实例。以下是kafka- Here .rest.properties的详细信息：
zookeeper.connect=z-3.msk.xxxx.xx.xxxxxx-1.amazonaws.com:2181,z-1.msk.xxxx.xx.xxxxxx-1.amazonaws.com:2181
bootstrap.se
浏览 4提问于2021-06-07得票数 0
回答已采纳
我正在尝试在docker上使用kafka。但是当运行docker compose时，kafka只是停留在配置模式上，而不是指示已经在运行。我为kafka主题做了列表，但它不工作或没有响应。这是我的docker-compose.yml： version: '3'
services:
zookeeper:
image: wurstmeister/zookeeper
container_name: zookeeper
hostname: zookeeper
ports:
- 2181:2181
environment:
浏览 196提问于2021-04-19得票数 1
我在我的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
回答已采纳
1回答
我是kafka的新手，并遵循本教程
我已经安装和配置了所有的zookeeper，kafka等，它工作得很好。但是当我运行任何命令时，我的输出终端窗口会在几秒钟内关闭，所以我看不到输出。是否有设置输出窗口时间的属性？
kafka-topics.sh --list --zookeeper localhost:2181
我使用此命令列出主题，但列出的主题窗口关闭，没有足够的时间让我看到。
浏览 17提问于2021-05-19得票数 0
我有点糊涂。我一直在跟踪这个开始和安装方法。
使用jar生成的connectorFYI：<code>H 110</code>设置安装AWS cli并配置它，并配置它安装maven编译连接器设置类路径，设置我有一个停靠器的属性文件-组合，创建所有容器(kafka、mqtt等)。(以上所有这些都是在前提下设置的)
然后，我在我的机器上执行了所有这些，而不是在卡夫卡容器上，所以在最后一步，当我尝试独立运行它时，它将如何工作？
version: '3'
services:
nodered:
container_name: nodered
浏览 12提问于2022-09-28得票数 0
下面是yml文件，用于在一个用于kafka和zookeeper的AWS实例中调出docker容器： version: '2'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka:
build: .
ports:
- "9092:9092"
environment:
KAFKA_ADVERTISED_HOSTNAME: <machines private ip>
浏览 24提问于2019-06-26得票数 0
1回答
我是卡夫卡的新手，我正在尝试创建一个演示卡夫卡服务器并使用它。
我已经创建了动物园管理员和卡夫卡容器使用一个码头-合成文件，他们是启动和运行良好。
如果我将docker exec放入Kafka容器并运行：
kafka-topics --create --zookeeper zookeeper-1 --replication-factor 1 --partitions 1 --topic demo-topic
主题已成功创建..。但是我想把Kafka broker旋转起来，然后以编程的方式创建主题，而不需要用户交互(最终将用于管道)。
我试过两种不同的卡夫卡图像(另一种是合流/cp).我还尝试在
浏览 2提问于2021-09-30得票数 0
回答已采纳
嗨，我的停靠的kafka服务器有一个问题。通过kafka-console-producer.bat发送到localhost时不创建消息，错误消息为：
向主题测试发送消息时出错，key: null，值:2字节，错误: 60000 ms后，元数据中不存在(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException:主题测试。
zookeeper和kafka服务器运行良好，我的yml如下所示：
version: '3'
浏览 1提问于2019-09-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
