我已经将Kafka服务添加到我的Cloudera集群中，当我尝试启动它时，它失败了，错误如下 Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/kafka/common/utils/KafkaThread : Unsupported major.minor version 52.0 据我所知，这是由于不同的java版本，Kafka需要1.8版本，而<
浏览 29提问于2019-12-24得票数 0
回答已采纳
在快速入门页面上运行kafka的说明对我不起作用。卡夫卡[info] Set current project to kafka-0-8-1-src (in buildfile:/shared/kafka-0.8.1-src/)
[info] Packaging /shared/kafka-0.8.1-src/targe
浏览 1提问于2014-04-17得票数 5
回答已采纳
我在kafka_home/bin/windows (按照建议的)。然后，我得到了与相同的问题，它建议从卡夫卡的家中启动程序。从windows文件夹启动时出现以下错误：org.apache.zookeeper.server.quorum.QuorumPeerConfi
浏览 14提问于2017-05-30得票数 3
回答已采纳
目前正在遵循https://github.com/openzipkin/zipkin快速入门，用于zipkin和kafka的docker启动。我设置了一个docker-compose来启动几个服务: kafka、zookeeper、neo4j和zipkin。- "9092:9092"depends_on:
- zookeeper
浏览 70提问于2021-07-19得票数 0
假设有以下场景：
我在本地启动zookeeper和一个kafka代理，并创建“测试”主题，如kafka快速入门：中所述。一段时间后，我关闭了我的本地kafka代理，看到producer继续生成消息，它没有抛出任何异常。最后，我再次启动kafka broker，producer能够重新连接到broker，并继续生成消息，但是，在kafka broker停机期间生成的所有消息都会丢失。当检测到健康的kafka</
浏览 1提问于2018-04-06得票数 1
我刚刚从Apache网站下载了Kafka 2.8.0，我正在尝试使用网站上的说明来设置。但是，当我试图启动zookeper服务器时，我得到的错误如下：
我的环境是
浏览 0提问于2014-07-30得票数 23
回答已采纳
我试图在Windows上安装消息队列，以测试的用途(而不是为了生产)。这是一篇好文章，但不幸的是，它已经过时了。
浏览 10提问于2014-04-16得票数 42
回答已采纳
有没有一种方法可以在每次运行之前删除主题中的所有数据或删除主题？我正在使用生产者从某个地方获取数据，并将数据发送到消费者消费的特定主题，我可以在每次运行时删除该主题中的所有数据吗？我只希望每次在主题中都有新的数据。有没有办法以某种方式重新初始化主题？
浏览 0提问于2013-07-19得票数 94
回答已采纳
我已经通过docker设置了NiFi (1.11.4)和Kafka(2.5) (下面是坞-组合文件，实际的NiFi流定义)。当试图跟进基本入门教程(如)时，这些教程结合了处理器，例如：
nifi: zookeeper ports:
- "2181
浏览 6提问于2020-06-10得票数 0
回答已采纳
2回答
我是kafka的新手，到目前为止，我在一台机器上运行kafka。我想在多台机器上的分布式环境中运行kafka。没有适当的文档说明这一点。任何关于这方面的文档或建议都会很有帮助。
浏览 0提问于2015-02-23得票数 5
如何在windows上运行kafka rest proxy。在windows文件夹中，我看不到kafka-rest-start。
浏览 1提问于2016-10-07得票数 3
这个命令不起作用，因为我们没有使用zookeeper：bin/kafka-topics.sh --list --zookeeper localhost:2181。
浏览 36提问于2017-06-07得票数 102
回答已采纳
我无法通过在windows上运行的intellij或vscode连接到运行在ubuntu上的kafka服务器(我在WSL2上尝试的第一个服务器)。我甚至试过使用虚拟机的IP地址，但没有成功。
浏览 0提问于2020-06-22得票数 0
我已经用Apache Kafka玩了几天了，这是我的问题，如果我设置了网站上“快速入门”部分中描述的本地测试，一切都很好，kafka生产者/消费者，zookeeper服务器和kafka代理都工作得很好。现在，如果我在远程服务器上运行(我们称之为node2)：- Zookeeper -port2181- Kafka Broker -port9092- kafka consumer
如果我在本
浏览 1提问于2013-03-05得票数 4
1回答
在轮询Kafka时，我使用subscribe()函数订阅了多个主题。现在，我希望设置要从每个主题中读取的偏移量，而不需要在每个主题的seek()和poll()之后重新订阅。
浏览 4提问于2017-08-15得票数 37
回答已采纳
5回答
我迷失在: Hadoop，Hbase，Lucene，Carrot2，Cloudera，Tika，ZooKeeper，Solr，Katta，Cascading，POI...如果你能帮我缩小我的特定场景的设置范围，那就太好了。到目前为止，我不确定以上哪种方法适合，而且看起来(一如既往)有不止一种方法来做要做的事情。有关存储在SQL数据库中的文档的元数据(发件人、收件人、日期、部门等)文档的主要来源将是ExchangeServer (电子邮件和附件)，但不仅仅是这样。基本上，他会看到一些搜索配置面板(java桌
浏览 0提问于2012-07-19得票数 5
我已经根据这里给出的说明使用docker安装了cloudera快速入门。/docker-quickstart/home/cloudera/cloudera-manager --express --force现在在我的主机上，我执行了docker-machine所以即使在做了端口转发之后...我无法从主机访问cloude
浏览 1提问于2015-12-21得票数 18
最重要的是，客户要求“实时”查看他们的数据，没有任何延迟时间，因此您的服务器需要快速处理和显示数据。Kafka是一个分布式流媒体平台，使公司能够创建实时数据源。例如，通过集成各种数据，如喜欢，页面点击，搜索，订单，购物车和库存，Kafka可以帮助实时将数据提供给预测分析引擎，以分析客户行为。那么 Kafka有哪些好处，您的公司为什么要采用它，以及您的IT团队成功实施它需要哪些技能？
浏览 7244提问于2018-09-14
·我正在使用Cloudera快速启动VM CDH 5.8.0。在我的窝里。 Hbase YARN Key-Value Indexer
在Cloudera·设置CLASSPATH。在链接中，我没有提到CLASSPATH中的“/path/to/scala.did”
浏览 3提问于2017-03-28得票数 0
回答已采纳
我已经在运行OS 10.8.5的iMac上设置了一个全新的Hadoop0.96.1.1-hadoop2和HBase 2.2.0实例。HMaster77273 ResourceManager76975 NameNode
我能够使用HBase shell创建和扫描表，如HBase快速入门指南中的示例所示。我也使用同一个用户运行Hbase和Hadoop (不确定这是否重要)。", "localhost&q
浏览 3提问于2014-01-28得票数 0
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
