在远程节点上部署了一些Apache Kafka实例后，我观察到Kafka存档中的kafka-server-stop.sh脚本出现了问题。#!\.Kafka' | grep java | grep -v grep | awk '{print $1}' | xargs kill -SIGTERM/var/lib/kafka
浏览 2提问于2014-08-29得票数 18
serverName;Database=dbName;user=un;password=pw", }我有一个类似的Kafka-Connect在运行作业的Kafka-connect服务器上的日志中，我看到了以下内容：
Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandlerconnect
浏览 112提问于2018-05-30得票数 1
1回答
我刚刚从Kafka和Kafka流媒体应用程序开始。我编写了一个，它从一个主题中消耗，处理这些消息，然后将它们发送到另一个主题。据我所知，我发现运行这个Kafka Stream应用程序编码的唯一方法是：
生成*.jar文件并从提示符中运行它。我想知道是否有任何方式自动运行卡夫卡流媒体应用程序的卡夫卡服务器启动。例如:将*.jar文件复制到卡夫卡安装的某个文件夹，并在启动卡夫卡服务器时自动运行此流应用程序。
浏览 1提问于2017-12-19得票数 4
回答已采纳
Logs arrives:
2021-06-23T13:51:16,681+02:00 WARN [kafka-admin-client-thread | adminclient-1] org.apache.kafka.clients.NetworkClient基本上，我只想在代理关闭时调用自定义方法。
浏览 1提问于2021-06-23得票数 0
3回答
我已经在亚马逊EC2实例上设置卡夫卡。如何才能使Kafka服务器为所有请求永久启动，即使在关闭SSH窗口之后也是如此。
谢谢。
浏览 1提问于2013-02-14得票数 24
回答已采纳
13回答
昨天我成功地设置了zookeeper和一个kafka代理。一切都按预期进行了。我关闭了kafka (ctrl + c)，然后关闭了zookeeper。今天我启动了zookeeper，当我启动kafka (bin/kafka-server-start.sh config/server0.properties)时，我得到了以下错误。at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:305)
at kafk
浏览 3提问于2016-09-29得票数 21
直到30分钟前，Kafka对我来说还很好。我使用的是windows，我使用的命令是：启动zookeeper然后启动kafka服务器。
现在，由于某些原因，zookeepe
浏览 7提问于2020-08-28得票数 1
在consumer上获取此kafka异常：at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
at org.apache.kafka.commo
浏览 4提问于2017-06-07得票数 3
我有大约20个进程在各自的服务器上生成日志(每个大约500MB)，到目前为止，我一直在将这些日志复制到中央服务器，并编写GUI并直接监视这些复制的日志文件的尾部。我设置了Kafka，并使用fluent-bit成功地将日志复制到每个服务器的一个分区中，这似乎非常有效。每天从日志中绘制数据；每个服务器进程1个图形(总共20个)将
浏览 31提问于2018-06-03得票数 0
1回答
我正在考虑创建一个独立的Kafka生产者，它作为守护进程运行，通过套接字获取消息，并将它们可靠地发送给Kafka。这是一个好主意，还是用每种常用语言编写生
浏览 3提问于2019-10-03得票数 0
如何从远程主机B访问或连接到在主机A的docker上运行的进程
考虑ip为192.168.0.3的主机A，它在端口3999上的docker上运行应用程序。准确地说，我在服务器上运行Kafka producer，并尝试使用Kafka-console-Consumer接收。
浏览 0提问于2017-03-10得票数 0
在对日志保持期进行适当配置之后，Kafka主题数据不会在windows中被删除。
以下错误将被记录在Kafka服务器日志中。由：\tmp\kafka-logs\TopicName-2\00000000000000007262.log java.nio.file.FileSystemException\tmp\kafka引起的-日志\TopicName -2\00000000000000007262.log.deleted:进程无法访问该文件，因为它正被另一个进程使用。计
浏览 0提问于2017-07-17得票数 3
回答已采纳
2回答
我希望根据SparkStreaming中数据的值更改Kafka主题目的地以保存数据。是否可以再这样做呢？当我尝试下面的代码时，它只执行第一个代码，而不执行较低的进程。.filter(f.col("value") == "A").writeStream.option("checkpointLocation&q
浏览 4提问于2021-03-05得票数 1
回答已采纳
我需要基于message属性下的主机名来使用kafka的消息。消息在Kafka主题下从下游被丢弃，在侦听器端，2进程被配置为相同的kafka队列，但运行在两个不同的服务器/主机名上。根据属性下的主机名过滤消息以将消息路由到正确的服务器的过程是什么。例如，message 1获得了具有主机名为serverA的属性，而message 2获得了具有主机名serverB的属性。消息1应由服务器A接收，消息2应由serverB接收。
浏览 8提问于2022-03-19得票数 0
在cpu中，工作者被描述为进程，所以在我的理解中，docs的核心。 但在相同的文档中，它们的目的是提供自动容错(在分布式模式下)，所以在我的理解中，不同的机器，因为进程级别的容错是没有意义的。
浏览 29提问于2019-12-05得票数 0
回答已采纳
2回答
因此，您拥有的订阅组越多，性能就越低，因为kafka需要将消息复制到所有这些组，并保证全部订单。
据我从Kafka文档中了解到，多个消费者群体的行为类似于单一消费者。那么，组的数量不应该增加任何开销，所有的数据都在一个位置上，只有偏移量是不同的。对吗？
浏览 3提问于2016-02-09得票数 7
回答已采纳
我有一个json，如下所示： "app" : "hw", "time" : "2018-05-06 12:53:04"我希望推送到S3的文件格式如下：我知道我可以做到：使用TimeBasedPartitioner和Topic.dir，但是如何同时放入这两个json字段呢？
浏览 12提问于2018-09-07得票数 3
我的管道是：
我可以用Kafka Connect替换Logstash组件吗？从文档中，我理解的是，如果Kafka Connect与Kafka的集群相同，那么这是很有可能的。但是我现在没有这个选项，因为我们的Kafka集群是多租户的，因此不能在集群上进行额外的进程。
浏览 6提问于2020-10-28得票数 0
有没有办法使用aws cloudwatch为服务器中运行的进程创建或跟踪指标 例如，我的实例运行以下进程 Python，kafka (动物园管理员) 有没有办法使用云监控来查看python、kafka
浏览 20提问于2019-09-24得票数 0
回答已采纳
4回答
我想将opc-ua数据映射到kafka主题中。例如，没有来自confluent的spefic连接器。
我将使用eclipse/milo ()。
浏览 41提问于2020-06-12得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
