我的输入配置如下所示： kafka { consumer_threads => 2
ssl_keystore_location => "/tmp/kafka.client.truststore.jks"
浏览 0提问于2021-10-30得票数 0
我试图从Java应用程序向Kafka发送消息。(Main.java:26)host.name=192.168.0.1advertised.host.name=192.168.0.1运行的Kafka是kafka_2.11-0.8.2.1，所以我使用了(我猜)适当的Java版本：
<
浏览 3提问于2015-06-16得票数 3
回答已采纳
我已经在我的centos服务器上安装了Apache。我只是想把一条消息写到另一台服务器上的一个主题上。因此，安装之后，我没有启动动物园管理员或Kafka服务器，而只是输入以下命令：我能够从我的服务器平xxx.yyy.com。)
60000 ms后元数据中不存在org.apache.kafka<
浏览 1提问于2019-04-23得票数 0
回答已采纳
1回答
请注意:我是第一次使用卡夫卡，对它的术语不太了解问题2:如果是，那么怎么做？任何架构参考。如果不是，那么如何使用python请求从多个API读取？问题4:我可以直接将这些数据从Kaf
浏览 5提问于2021-08-11得票数 0
我正在尝试让一个Kafka消费者同时消费来自Kafka的消息。/**我已经更新到Storm 2.0.0，我使用storm-kafka-client。但是，如果我将风暴队列配
浏览 8提问于2019-11-20得票数 0
回答已采纳
我让kafka和zookeeper在ec2实例上以独立模式运行。我在上面创建了一个名为dev_spark1的主题。但当我试图从命令行运行consumer时，给出了以下命令错误： Exception in thread "main:171)
at kafka.consumer.ZookeeperConsumerConnector.<in
浏览 36提问于2017-03-16得票数 2
我们有3个kafka代理节点和3个zookeepers服务器的kafka集群 kafka版本- 10.1 ( hortonworks ) 据我所知，因为所有元数据都位于zookeeper服务器上，而kafka代理正在使用这些数据( kafka通过端口2181与zookeeper服务器交谈) 我想知道是否每台kafka机器都与集群中的其他kafka通信，或者kafka只在zookeepers服
浏览 34提问于2019-02-07得票数 1
我在kubernetes集群中运行了一个kafka安装。下面是我的spring boot配置 spring: consumer: auto-offset-reset9092" 在启动时设置消费者时，组id和auto-offset-reset是从上面的配置中正确传入的。但是，bootstrap-servers配置不是这样的，根据下面的日志，应用程序实际上使用的是localhost:9092 201
浏览 19提问于2019-03-11得票数 2
我计划使用两台服务器构建一个Kafka集群，并在这两台服务器上托管。就像。目前，我在两个服务器上运行两个动物园管理员，在每个服务器上运行一个Kafka，在Kafka配置中，它们指向所有动物园管理员。
有更好的方法吗？
浏览 1提问于2020-02-27得票数 0
回答已采纳
: container_name: kafka - "9092:9092" KAFKA_ADVERTISED_HOST_NAME: kafka my-app:那么错误是代理可能是不可用的。
如果有人能引导
浏览 2提问于2020-11-03得票数 4
我是卡夫卡的新手。我正在开发Spring-Kafka POC。我们的KAFKA服务器是Kerberized的。有了所有必需的配置，我们就能够访问Kerberized化的Kafka服务器了。现在我们有了另一个需求，我们必须使用来自非Kerberized(简单Kafka消费者) Kafka服务器的主题。我们可以在单个应用程序中通过创建另一个具有自己的侦听器的KafkaConsumer来做到这一点吗？
浏览 10提问于2017-08-07得票数 1
2回答
我是卡夫卡技术的新手。我已经使用Ambari设置了一个基本的单节点集群。我对动物园管理员的角色很困惑。我知道动物园管理员需要奇数的节点，所有的kafka节点上都安装了动物园管理员，然后如何使用偶数节点来运行Kafka。如果这是真的，它将限制卡夫卡的奇数节点以及。我可以在不同的节点上安装动物园管理员，在不同的节点
浏览 1提问于2018-10-25得票数 0
回答已采纳
我正在尝试构建一个简单的spring boot Kafka Consumer来消费来自kafka主题的消息，但是没有消息被消费，因为KafkaListener方法没有被触发。我在其他答案中看到，以确保AUTO_OFFSET_RESET_CONFIG设置为“最早”，并且GROUP_ID_CONFIG是唯一的，这是我所做的，但是KafkaListenerMethod仍然没有触发: 'application'
浏览 517提问于2020-01-07得票数 1
2回答
如何生成和使用来自不同服务器的消息？我试过了Quickstart教程，但是没有关于如何设置多服务器集群的说明。我的脚步1)bin/zookeeper-server-start.sh config/zookeeper.properties3)bin/kafka-topics.sh --create --zookeeper localhost
浏览 6提问于2017-04-03得票数 1
我正在尝试启动kafka模式注册表，但收到以下错误:无法将Noop记录写入kafka存储。堆栈跟踪如下所示。我检查了和动物园管理员，卡夫卡经纪人的联系-一切都很好。我可以给卡夫卡发消息。我试图删除_schema主题，甚至重装kafka，但这个问题仍然存在。昨天一切正常，但是今天，在重启我的流浪汉机器后，这个问题出现了。有什么我能做的吗？(io.confluent.kafka.schemaregistry.storage.KafkaStore:172)
[2015-11-19 19:12:27,262] I
浏览 9提问于2015-11-20得票数 7
3回答
我是卡夫卡和Hadoop技术的新手。即单个代理集群，我已经完成了以下工作：2)用java相关条目更新~/.bashrc and ~/.nash_profile文件4)一旦我试图启动kafkabroker，它就会向我抛出以下错误信息：Java HotSpot(TM) 64-Bit ServerAn error report file
浏览 3提问于2015-08-13得票数 3
回答已采纳
我想通过localstack测试使用kafka的应用程序。localstack支持kafka吗？
如果是，它在哪个端口上运行？
浏览 0提问于2020-06-24得票数 0
1回答
对于事件驱动的后端，由于Django太慢，无法处理客户端发送给我的数百万请求，所以我考虑使用Kafka +一个类似于物化的流数据库。
但是，我仍然不清楚如何将请求路由到这些不同的端点。我是否需要以诸如Golang/Rust这样的快速方式编写端点才能将客户端负载发送给Kafka？还是客户直接与卡夫卡沟通？像Nginx这样的东西是路由这些请求的正确方式吗？
浏览 5提问于2022-09-06得票数 0
但是，当我使用带有运行代理地址的脚本kafka-consumer-groups.sh作为引导服务器时，我会得到以下错误。kafka@mirror-maker-0:/opt/kafka/bin$ /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server <node-ip(org.apache.kafka.clients.NetworkC
浏览 16提问于2022-03-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
