无法启动Kafka
Kafka是一种分布式流处理平台，用于构建高性能、可扩展的实时数据流应用程序。它具有高吞吐量、低延迟、持久性和容错性等特点，被广泛应用于日志收集、事件流处理、消息队列等场景。
Kafka的优势包括：
- 高吞吐量：Kafka能够处理大规模数据流，并保持低延迟。
- 可扩展性：Kafka的分布式架构允许在集群中添加更多的节点，以满足不断增长的数据处理需求。
- 持久性：Kafka将数据持久化到磁盘上，确保数据不会丢失。
- 容错性：Kafka通过数据复制和分区机制来提供高可用性和容错性。
- 多语言支持：Kafka提供了多种编程语言的客户端，方便开发人员使用各种编程语言进行数据处理。
Kafka的应用场景包括：
- 日志收集：Kafka可以用作日志收集系统的中间件，将日志数据从各个应用程序发送到中心化的存储和分析系统。
- 数据流处理：Kafka可以用于构建实时数据流处理应用程序，对数据进行实时处理、转换和分析。
- 消息队列：Kafka提供了高性能的消息传递机制，可以用于构建异步通信系统和解耦应用程序的组件。
- 事件驱动架构：Kafka可以作为事件驱动架构的基础设施，用于处理和分发事件。
腾讯云提供了一系列与Kafka相关的产品和服务，包括：
- 云消息队列CMQ：腾讯云的消息队列服务，提供高性能、可靠的消息传递能力，可与Kafka进行集成。 链接：https://cloud.tencent.com/product/cmq
- 云原生消息队列TDMQ：腾讯云的云原生消息队列服务，提供高性能、可靠的消息传递能力，支持Kafka协议。 链接：https://cloud.tencent.com/product/tdmq
- 云流数据总线DataWorks：腾讯云的数据集成和流处理平台，支持Kafka作为数据源和目标，实现数据的实时流转和处理。 链接：https://cloud.tencent.com/product/dw
总结：Kafka是一种分布式流处理平台，具有高吞吐量、可扩展性、持久性和容错性等优势。它适用于日志收集、数据流处理、消息队列等场景。腾讯云提供了与Kafka相关的产品和服务，包括云消息队列CMQ、云原生消息队列TDMQ和云流数据总线DataWorks。
相关·内容
Error: failed to create containerd task: failed to create shim task: OCI runtime create failed: runc create failed: unable to start container process: exec: "/opt/kafka/kafka_connect_run.sh": stat /opt/kafka/kafka_connect_run.sh: no such file or directory: unknown
这是在kubectl kafka连接器吊舱中得到的，它
浏览 31提问于2022-10-18得票数 0
Kafka服务器无法通过confluent start命令启动。
命令行：
~]# sudo confluent start
zookeeper is already running. Try restarting if needed
启动kafka
-Kafka failed to start
kafka is [DOWN]
Cannot start Schema Registry, Kafka Server is not running. Check your deployment
浏览 0提问于2018-04-05得票数 0
我们有3个代理节点的Kafka集群。当所有的都启动并运行时，消费者能够从Kafka读取数据。然而，如果我停止了所有的Kafka服务器，并且只启动了2个Kafka服务器，除了最后一个停止的服务器，那么消费者就无法连接到Kafka集群。这背后的原因可能是什么？提前谢谢。
浏览 37提问于2020-11-27得票数 0
直到30分钟前，Kafka对我来说还很好。我使用的是windows，我使用的命令是：
c:\kafka>.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
启动zookeeper然后
c:\kafka>.\bin\windows\kafka-server-start.bat .\config\server.properties
启动kafka服务器。
现在，由于某些原因，zookeeper无法工作。也就是说，当我运行命令来启动zookeeper时，什么都没有发生，在我的终端中跳过了一行，我只需
浏览 7提问于2020-08-28得票数 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
回答已采纳
如何在后台运行用ansible编写的Kafka broker启动脚本，当我正常运行它时，它在前台执行，我无法恢复对终端的控制，如果我关闭终端或Ctrl+c它们，Kafka broker将被停止
我的目标是在CLI上启动Kafka broker之后，我需要在该终端上运行几个命令来执行其他一些任务。
ansible kafkabrokers -a "~/kafka_2.11-0.9.0.0/bin/kafka-server-start.sh ~/kafka_2.11-0.9.0.0/config/server.properties "
nohup和“&”都不起作用
浏览 5提问于2016-03-29得票数 1
回答已采纳
1回答
我无法启动zookpeer来进一步启动Kafka。我的文件夹结构是：
根
bin
zookeper-server-start.sh
- config
- zookeper.properties
我试过跑步
./zookeeper-server-start.sh ../config/zookeeper.properties
我得到了以下错误：
/d/Programs/Kafka/kafka_2.12-2.2.0/bin/kafka-run-class.sh: line 306: C:\Program: No such file o
浏览 1提问于2019-06-29得票数 0
回答已采纳
1回答
当我在我的机器上启动Kafka时，出现了这个错误。 giangnt@node2:/opt/kafka/kafka_2.12-2.6.0/bin$ nohup: ignoring input and appending output to 'nohup.out'
[1]+ Exit 127 nohup ./kafka-server-start.sh /opt/kafka/kafka_2.12-2.6.0/config/server.properties
giangnt@node2:/opt/kafka/kafka_2.12-2.6.0/bin$
浏览 169提问于2021-01-23得票数 0
我已经创建了与卡夫卡经纪人和动物园管理员对接开始运行脚本。如果我重新启动，它将正常启动并运行ok (Windows -> WSL ->两个tmux窗口，一个会话)。如果我关闭卡夫卡或动物园管理员，并再次启动它，它将正常连接。
当我停止停靠容器(停靠停止my_kafka_container)时会出现问题。然后从我的脚本开始。/run_docker。在启动之前的脚本中，我删除旧容器docker rm my_kafka_container，然后运行码头。
动物园管理员正常启动，在文件meta.properties中，从以前的启动开始就有旧的集群id，但是由于某种原因，meta.prope
浏览 0提问于2020-01-04得票数 28
回答已采纳
我有一个Spring Boot应用程序，其中有一个Kafka消费者和生产者。还有一个用于创建主题的bean。 例如： @KafkaListener(topics = "myTopic")
public void doSomething() {
// do something on receipt of the message
}
@Bean
public NewTopic topic(){
return TopicBuilder.name("myTopic")
.partitions(2)
浏览 149提问于2020-09-24得票数 0
回答已采纳
我的kafka经理无法更新消费者信息并保留已删除的消费者组列表，因此我尝试重新启动kafka-manager。(我用的是卡夫卡经理1.3.3.22和kafka 2.12-2.1.1)
但是卡夫卡管理器和/bin/kafka管理器命令中的README.md似乎没有提供停止/重新启动。
有没有办法安全地重启或终止卡夫卡-经理？没有“杀死-9 PID”的推荐
浏览 6提问于2020-05-29得票数 3
回答已采纳
我正在使用多个kafka连接器。但是每个连接器都在同一个connect.log文件中写入日志。但我希望连接器写入不同的日志文件。为此，在启动期间，我需要更改默认的/etc/kafka/connect-log4j.properties文件。但是无法改变它。 示例启动脚本： /usr/bin/connect-standalone ../properties/sample-worker.properties ../properties/sample-connector.properties > /dev/null 2>&1 & 在连接器启动期间，有没有办法更改默认的
浏览 57提问于2021-09-10得票数 0
回答已采纳
2回答
我正在尝试在监控模式下运行kafka，这样它就可以在关机时自动启动。但是，运行kafka的所有示例都使用shell脚本，并且supervisord无法指出要监视哪个PID。有没有人能建议一下如何实现kafka的自动重启？
浏览 2提问于2014-01-16得票数 1
我试图开始合流在一个运行的码头形象为ubuntu。下面是命令的错误：
root@linuxkit-025000000001:/# /my/dir/path/confluent-4.0.0/bin/confluent start
以下是输出日志：
起动动物园管理员
动物园管理员起床了
启动卡夫卡
卡夫卡没能开始
卡夫卡倒下了
无法启动架构注册表，Kafka Server未运行。检查您的部署
我试着启动卡夫卡：
# cd confluent-4.0.0
# ./bin/kafka-server-start ./etc/kafka/server.properties
以下是重要的错误日志：
浏览 3提问于2018-03-21得票数 1
回答已采纳
在卡夫卡重新启动后，春季启动的消费者微型服务无法向某个主题发送消息。
使用坞群配置，我安装了带有1个kafka broker和2个spring引导微服务(生产者和消费者)的单节点集群。我使用的是弹簧引导2.0.3
消费者和生产者(spring )在同一个覆盖网络“network”上，因此他们访问kafka的服务名为"kafka:9092“。
第一次发车一切都很顺利。
然后卡夫卡才重新开始，之后消费者就无法再发送来自卡夫卡主题的信息了。
由于docker-compose.yml (例如max_attempts: 3 => max_attempts: 4)中的小改动，
浏览 0提问于2019-05-08得票数 1
你好，我是德鲁伊和卡夫卡的初学者。我在同一个localhost上运行kafka服务器和druid服务器 我已经通过跟随./bin/zookeeper-server-start.sh config/zookeeper.properties在kafka中运行了zookeeper，并通过跟随./bin/kafka-server-start.sh config/server.properties运行了kafka服务器。 我尝试将kafka服务器连接到德鲁伊服务器以输入数据。当我尝试运行druid的zookeeper时，按照druid ./bin/start-micro-quickstart的文档，结
浏览 85提问于2021-07-22得票数 0
我通过发出"./bin/confluent“命令启动了。然后我使用kafka连接将kafka数据汇到mysql中。
通过执行以下命令，我可以在独立模式下很好地运行kafka connect：
/bin/connect-独立的./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/adstats-jdbc-sink.properties
然后我关闭上面的命令并通过命令切换到分布式模式：
./bin/connect分布式./etc/schema-registry/conne
浏览 0提问于2018-08-09得票数 1
我正在尝试运行程序来连接Kafka和MQ，从ubuntu使用下面的命令，但得到下面的错误 错误:无法找到或加载主类org.apache.kafka.connect.cli.ConnectStandalone 命令: CLASSPATH=/target/kafka-connect-mq-sink--jar-with-dependencies.jar ./bin/connect-standalone.sh config/connect-standalone.properties ~/mq-sink.properties 请告知如何修复此错误
浏览 75提问于2020-07-27得票数 0
嗨，这是我的剧本
---
- hosts: pupservers
sudo: yes
tasks:
- name: start kafka
command: /home/ec2-user/kafka_2.11-0.9.0.0/bin/kafka-server-start.sh /home/ec2-user/kafka_2.11-0.9.0.0/config/server.properties
我实际上试着启动kafka broker-实际的命令是
bin/kafka-server-start.sh config/server.properties
当我在kafka br
浏览 5提问于2016-03-19得票数 1
回答已采纳
当将项目从Springboot 2.0升级到2.1时，我们还将spring-kafka-integration从3.0.1升级到3.2.1。在这样做的过程中，我们的测试现在都无法启动，原因是：
org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-1, groupId=x] Connection to node -1 could not be established. Broker may not be available.
org.apache.kafka.clients.NetworkClient
浏览 0提问于2019-05-03得票数 4
回答已采纳
WHen我启动了kafka，它很快就失败了，同时抱怨它无法连接到zookeeper。我将zookeeper作为独立的集群/集成运行。我之所以感到困惑，是因为服务器之间没有防火墙( zookeeper-shell.sh测试证明了这一点)。
来自/var/log/kafka/server.log
2016-02-24 16:07:12,101 INFO kafka.server.KafkaServer: [Kafka Server 1], Connecting to zookeeper on 10.7.20.100:2181,10.7.20.101:2181,10.7.20.102:2181
20
浏览 3提问于2016-02-25得票数 7
回答已采纳
集群中有4个Kafka节点，一个topic分成40个分区，副本数为2，Kafka版本为2.3.1。 两个Kafka节点同时死掉，无法重新启动，Kafka日志丢失，如何恢复？ 我确信我丢失了一些数据，因为一些分区丢失了(一些分区只在已死的节点上有副本)。 我尝试添加两个新的Kafka节点，并将分区重新分配给所有4个可用的Kafka节点。最后，丢失的分区不会重新分配给两个新的Kafka节点。客户端不能发布到丢失分区的数据。
浏览 116提问于2020-01-03得票数 2
回答已采纳
下面是我的卡夫卡消费者
@Service
public class Consumer {
private static final Logger LOGGER = Logger.getLogger(Consumer.class.getName());
public static Queue<ProductKafka> consumeQueue = new LinkedList<>();
@KafkaListener(topics = "#{'${spring.kafka.topics}'.split('\\\\
浏览 1提问于2021-02-10得票数 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
我在windows中启动kafka服务器有一个问题。
命令.\bin\windows\kafka-server-start.bat .\config\server.properties
错误消息：
命令的语法不正确。错误:无法找到或加载主类Files\IBM\WebSphere
有什么想法吗？
浏览 2提问于2016-11-08得票数 3
我很难在Windows 10机器上配置kafka和spring。
我是按照指南做的，这是我在YouTube 上发现的。
我不能以任何方式在本地联系。
spring应用程序非常简单，它的任务只是连接到站立服务器。
我已经花了很多时间寻找解决方案，没有什么能帮到我。我试了很多次。将其更改为server.properties listenera侦听器= PLAINTEXT: //127.0.0.1: 9092__。我将Java版本更改为jre 8.241__。
spring应用程序无法连接到代理。
请帮帮忙。
更新
键入之后，启动Kafka服务器：
bin/kafka-server-sta
浏览 1提问于2020-06-24得票数 1
回答已采纳
我无法在本地获取异常中启动zookeeper 错误:无法找到或加载主类software\kafka_2.12-2.3.0\libs\activation-1.1.1.jar；
浏览 14提问于2019-10-08得票数 1
我在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
我有下面的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
回答已采纳
我已经在云服务器上安装了kafka，希望从本地系统连接cloud-kafka服务器
我的云kafka服务器内部IP：
10.340.0.90
我的云kafka服务器公网IP：
aa.xx.yy.zz
我的本地系统IP：
172.168.1.100
文件名：config/server.properties
取消注释并更改了以下行：
#advertised.listeners=PLAINTEXT://:9092
to
advertised.listeners=PLAINTEXT://10.340.0.90:9092
重新启动了卡夫卡，动物园管理员
尽管如此，我还是无法从我的本地网络连接远程kafk
浏览 5提问于2018-05-23得票数 2
分布式服务启动成功: 2021-10-17 18:04:29,693 INFO Started Kafka {/，null，AVAILABLE} (org.apache.kafka.connect.runtime.rest.RestServer:319) 2021-10-17 18:04:29,693 INFO REST资源已初始化；服务器已启动，准备处理请求(org.apache.kafka.connect.runtime.rest.RestServer:319) 2021-10-17 18:04:29,693 INFO o.e.j.s.ServletContextHandler@1422
浏览 38提问于2021-10-17得票数 2
我有一个以FIPS模式运行的kafka集群，配置如下。
Brokers: 3, Zookeeper Nodes: 3
Kafka: 2.0.0, Scala: 2.12
Zookeeper: 3.4.14
Java - 8
bc-fips - 1.0.1
此群集运行良好，处于健康状态。
目前，我们已经升级了Kafka(2.4.0)和Java(11)版本，之后FIPS集群无法加载bc库并启动kafka。新的集群配置：
Brokers: 3, Zookeeper Nodes: 3
Kafka: 2.4.0, Scala: 2.12
Zookeeper: 3.4.14
Java - 11
bc-fi
浏览 1提问于2020-05-19得票数 1
回答已采纳
无法启动卡夫卡服务器，但我的动物园管理员正在正常工作
C:\kafka> .\bin\windows\kafka-server-start.bat .\config\server.properties 系统找不到指定的路径.
\bin\windows\kafka-server-start.bat .\config\server.properties 'wmic‘不被识别为内部或外部命令、可操作的程序或批处理文件。
卡夫卡最新版本3.0.0
浏览 4提问于2021-12-02得票数 0
我并在intelliJ IDEA 2018.3中的maven项目中获取此依赖文件
我的pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="ht
浏览 0提问于2019-02-19得票数 1
回答已采纳
我的应用程序可以在eclipse中运行，也可以通过gradlew bootRun运行。但是，当我通过gradlew构建构建一个“fat”jar文件，然后通过java -jar app.jar启动应用程序时，我得到的错误如下：
错误o.a.k.c.s.ssl.SslEngineBuilder -无法获得密钥存储的修改时间: kafka_truststore.jks java.nio.file.NoSuchFileException: kafka_truststore.jks
kafka_truststore.jks在application.properties中定义如下
kafka.trusts
浏览 1提问于2020-12-22得票数 0
我使用以下卡夫卡码头形象：
我可以使用以下属性启动Apache：
<KAFKA_ADVERTISED_HOST_NAME>${local.ip}</KAFKA_ADVERTISED_HOST_NAME>
<KAFKA_ADVERTISED_PORT>${kafka.port}/KAFKA_ADVERTISED_PORT>
<KAFKA_ZOOKEEPER_CONNECT>zookeeper:2181</KAFKA_ZOOKEEPER_CONNECT>
<KAFKA_MESSAGE_MAX_BYTES>
浏览 0提问于2018-08-25得票数 2
我一直在使用CONDUKTOR应用程序连接到KAFKA。但是由于某种原因，Conduktor连接被禁用(屏幕截图中突出显示为黄色)，而且我无法连接到kafka，即使在重新启动系统两次之后。
附上截图。任何帮助都是非常感谢的。
谢谢,
浏览 2提问于2020-01-24得票数 3
1回答
我无法通过代码连接到本地运行的Kafka实例-我可以使用Kafka-Console-Producer和Kafka-Console-Consumer成功连接，但当我使用Kafka Java SDK并简单地使用Java Producer连接并生成任何消息时，会失败，并显示以下错误：
[Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
[kafka-producer-network-t
浏览 468提问于2020-05-25得票数 2
回答已采纳
我正在使用VMware使用ubuntu，我已经在其中安装了hadoop单节点集群。然后，我安装了动物园管理员，并运行动物园管理员。然后，当我运行我的"Apache“时，它会抛出一个错误。
未识别的VM选项'+UseCompressedOops'
无法创建虚拟机
单一@ubuntu：~/瑜伽/动物园管理员-3.4.5/bin$ ./zkServer.sh启动
默认情况下启用JMX
使用配置: /home/single/yoga/zookeeper-3.4.5/bin/../conf/zoo.cfg
启动动物园管理员..。启动
单发@ubuntu：~//kafka_2.8.
浏览 2提问于2014-03-11得票数 4
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
我启动了一个docker容器来运行Kafka服务器
docker run -p 2181:2181 -p 9092:9092 --env ADVERTISED_HOST=192.168.99.100 --env ADVERTISED_PORT=9092 spotify/kafka
我找到了Docker容器的IP地址。这是172.17.0.2，我可以ping通此地址。
现在我想要一个发送消息的生产者：
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='172.17.0.2:9092&#
浏览 4提问于2018-01-15得票数 6
我有一个独立的kafka经纪人，我试图配置SASL。配置在下面。我正在尝试在代理上设置SASL_PLAIN身份验证。
我的理解是listener.name..。在server.properties中的配置，我不应该需要jaas文件。但我尝试了一个，看看这是否是一个更好的方法。
我试验了这些命令中的每一个，但这两个命令都会导致相同的异常。
sudo bin/kafka-server-start etc/kafka/server.properties
sudo -Djava.security.auth.login.config=etc/kafka/kafka_server_jaas.con
浏览 1提问于2019-01-08得票数 3
回答已采纳
我们使用的是卡夫卡版本- 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
回答已采纳
我们正在使用Hazelcast Jet0.4版本来读取Kafka来源的信息，处理这些消息并将其写入Kafka。由于卡夫卡是由一个外部团队管理的，我们无法控制卡夫卡抛出的各种异常。
例如，我们收到以下异常:无法完成提交，因为组已经重新平衡并分配了分区
当我们收到此错误时，Hazelcast Jet实例将被关闭。因此，我们的应用程序变得不可用，我们必须重新启动应用程序。
我们正在研究在这些错误期间自动重新启动Jet实例的可能性。
谢谢你的帮忙!
浏览 1提问于2018-06-29得票数 0
我在我的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
回答已采纳
如果我使用KafkaUtils.createDirectStream读取消息，如何在Kafka中存储消息偏移量。每次应用程序运行down.It时，Kafka都会丢失偏移值，然后读取auto.offset.reset中提供的值(这是最新的)，并且在应用程序的停止-启动间隔内无法读取消息。
浏览 21提问于2019-01-14得票数 1
1回答
我正试图使用apache-kafka二进制文件中的kafka-控制台-生产者来生成消息，并在春季启动时从消费者设置中消费。使用者使用avro架构。
当以json格式生成消息时，我的使用者抛出异常--“无法序列化”。
我找到了一个解决方案来使用“7.1”，其中有kafka-avro-console-producer。它支持avro，但它是企业版。
是否有一种方法可以使用apache-kafka与kafka控制台生产者一起使用avro模式来生成/消费消息？
浏览 6提问于2022-04-26得票数 0
回答已采纳
我跟踪了一个。在我重新启动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
我正在一个亚马逊网络服务t2实例(一个有1 1gb内存的实例)上安装kafka。
(1)下载kafka_2.11-0.9.0.0 (2)运行zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties (3)尝试运行bin/kafka-server-start.sh config/server.properties
Java HotSpot(TM) 64位服务器VM警告:信息: os::commit_memory(0x00000000c0000000,1073741824，0)失败；错误=‘无法分配内存’(errno=1
浏览 4提问于2016-01-24得票数 2
回答已采纳
我无法启动Zookeper。我已经尝试删除文件夹，从头开始重新开始，也尝试更改目录。但是，我在CMD中得到了以下错误：
D:\Zookeper & Kafka\kafka_2.11-1.0.0\bin\windows>zookeeper-server-start.bat ..\..\config\zookeeper.properties
'Kafka\kafka_2.11-1.0.0\bin\windows\..' is not recognized as an internal or external command,
operable program or b
浏览 3提问于2017-11-06得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
