回答情况：
提问时间：
问题标签：
我已经从Kafka下载页面下载了Apache Kafka。我已经把它解压缩到/opt/apache/installed/kafka-0.7.0-incubating-src了。说您需要启动zookeeper，然后通过运行以下命令启动Kafka：我使用的是单独的Zookeeper当我按照快速入门页面中的说明运行Kafka
浏览 6修改于2012-05-05得票数 16
回答已采纳
1回答
但我一直在kafka-o日志中看到错误java.net.UnknownHostException: kafka-0.kafka-headless.kafka.svc.cluster.local。我登录到pod (kafka-o)并运行nslookup查找kafka-0.kafka-headless.kafka.svc.cluster.local，但IP得到了解决，没有出现任何问题 root@kafka-0:/# nslook
浏览 471修改于2021-07-26得票数 0
回答已采纳
每当我尝试重启kafka时，都会出现以下错误。一旦我删除了/tmp/kafka-logs，它就会被解决，但它也会删除我的主题。有没有办法解决这个问题？ERROR Error while deleting the clean shutdown file in dir /tmp/kafka-logs (kafka.server.LogDirFailureChannel:115)
at kafka.utils.CoreUtils$.inLock(CoreU
浏览 3修改于2018-11-03得票数 7
有没有办法通过编程获取kafka集群的版本？例如使用AdminClient应用程序接口。
我想在消费者/生产者应用程序中识别kafka集群的版本。
浏览 1提问于2019-07-12得票数 3
卡夫卡确认和卡夫卡消费者commitSync ()有什么区别？ 两者都用于手工抵销管理，希望两者同步工作。 请协助
浏览 17修改于2020-01-23得票数 7
回答已采纳
我正在使用mac并通过安装zookeeper和kafka通过使用以下命令：kafka-server-start /usr/local/etc/kafka/server.properties
connect-distributed&
浏览 3提问于2020-08-05得票数 0
我从链接中下载了Scala2.11-kafka_2.11-2.1.0.tgz：和我完成了以下步骤：
>kafka-server-s
浏览 0修改于2020-04-21得票数 2
如果我的问题到处都是，很抱歉，但我是Apache Kafka的新手，目前我正在尝试使用Windows操作系统将Teradata表(在VM上)中的数据导入到Kafka中。4-通过Kafka的kafka-console-consumer.bat脚本使用生产者的输出，该脚本随Apache Kafka下载的压缩包一起提供。我读了一些帖子，发现要连接Kafka和Teradata，我需要使用Kafka connect。但有几件事让我感到困惑：
1-我遇到的大多数帖子都使用Confl
浏览 0提问于2020-10-28得票数 2
我正在尝试设置一个Kafka集群(实际上是集群中的第一个节点)。但是，在尝试使用消息时，我得到了相同的错误。
有什么帮助和建议吗？"main" java.net.UnknownH
浏览 1修改于2019-11-05得票数 18
回答已采纳
我们有3个kafka代理节点和3个zookeepers服务器的kafka集群 kafka版本- 10.1 ( hortonworks ) 据我所知，因为所有元数据都位于zookeeper服务器上，而kafka代理正在使用这些数据( kafka通过端口2181与zookeeper服务器交谈) 我想知道是否每台kafka机器都与集群中的其他kafka通信，或者kafka只在zookeepers服务器上获取/放置数据那么kafka
浏览 34修改于2019-05-05得票数 1
我需要从Kafka主题获取消息，并通过基于HTTP的API通知其他系统。即从topic获取消息，映射到第三方API并调用。我打算为此编写一个Kafka Sink连接器。对于这个用例，Kafka Connect是正确的选择，还是我应该使用Kafka客户端。
浏览 2修改于2018-09-26得票数 8
(kafka.network.Acceptor)
kafka |KAFKA_LISTENERS: 'SSL:/&
浏览 61修改于2022-02-28得票数 -1
回答已采纳
我想在Apache Kafka和Apache Zookeeper进程停止时收到邮件提醒，当它停止时会自动重新启动这两个进程。Apache Kafka和Apache Zookeeper都不创建任何pid文件，也不属于init脚本。我的Apache Zookeeper和Apache Kafka的monit控制文件定义如下 i
浏览 4提问于2016-06-06得票数 0
我正在尝试使用Kafka Connect和kafka-connect-twitter在Github的jcustenborder中将Twitter推文引入Kafka。connect avro docker属性文件在kafka-connect-twitter存储库中运行mvn clean包后，似乎希望使用target/kafka-connect-target/usr/share/kafka-connect中提供的jars。我使用的是Kafka<
浏览 47修改于2021-11-13得票数 0
回答已采纳
在我们的docker-swarm中运行kafka connect，使用以下组成文件： cp-kafka-connect-node: CONNECT_LOG4J_ROOT_LEVEL: TRACE
浏览 22提问于2019-01-19得票数 1
回答已采纳
我第一次在windows 7上运行Kafka，启动Kafka服务时出错
在C:\kafka_2.12-2.0.0\config\server.properties中，log.dirs更改为log.dirs=C:/<
浏览 0修改于2020-06-20得票数 0
我正在尝试在我的项目中使用Spring Kafka，其中spring boot版本是2.2.2.RELEASE，kafka版本是2.3.x。implementation 'org.springframework.kafka:spring-kafka' 我已经设置了KafkaConfig类和侦听器类： @EnableKafka
@Configurationexception is org.springframework.beans.factory.BeanCreationException: Error
浏览 473提问于2020-10-22得票数 1
回答已采纳
Schema registry因此，集群最终应包括：安装在3 zookeeper上的kafka01, kafka</em
浏览 2修改于2020-08-20得票数 1
回答已采纳
有没有人能帮我理解一下，
apache apex有没有内置的kafka输入操作符，可以从Kafka 0.9安全kafka主题中读取？
浏览 0提问于2016-10-31得票数 4
\kafkapublisher.go:8:65: undefined: kafka.Message
在我的kafkapublisher.go文件中，我已经导入了kafka依赖：
imp
浏览 2修改于2021-09-04得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号