如何在关闭kafka服务器之前获取kafka服务器的所有详细信息，如kafka主题名称、分区、组等。并使用这些信息来准备新的kafka服务器？ 此类型的备份是否有任何选项？
浏览 25提问于2019-01-30得票数 1
回答已采纳
我有一个脚本来获取特定Kafka主题中的消息计数，它只能在Kafka托管的服务器中执行。脚本的输出必须移动到配置单元/HDFS。那么我可以先把它移到Kafka topic，然后再用HDFS Sink连接器移到HDFS吗？如果是，如何将脚本生成的数据移动到Kafka topic？如果有更好的解决方案，也请让我知道。
浏览 2提问于2018-12-26得票数 0
2回答
我使用的是confluent-Kafka和python。我想将Kafka连接到Hdfs，并将一些特定的数据直接存储在Hdfs中。我找到了confluent HDFS连接器，但我不知道如何将它与我的python脚本连接起来。有什么想法吗？或者有什么替代方法可以将消息直接从Kafka存储到Hdfs？
浏览 1提问于2020-06-08得票数 0
下面的属性被添加到$KAFKA_HOME/config/connect-standalone.properties中，除了需要的常规信任之外。即使在$KAFKA_HOME/config/producer.properties中提供了与auth相关的属性之后，也没有运气。
能够通过$K
浏览 10提问于2022-08-24得票数 0
回答已采纳
我是第一次接触kafka connect。我在服务器上配置了一个接收器连接器，用于将数据从kafka队列发送到elastic search。我已经创建了一个项目来产生数据到kafka队列。这是成功的，因为当我尝试使用Kafka consumer消费数据时，我可以看到数据。现在，我需要在Java项目中进行哪些配置，以便启动接收器连接器并将数据从Kafka队列转移到elastic search。或者这应该是自动发生的，因为连接器配置已经指向elk url，并且其他<
浏览 4提问于2021-07-04得票数 0
尝试使用netbeans IDE 7.3.1中的默认设置启动glassfish服务器时，出现以下错误：我能做什么?如何将glassfish设置为使用其他地址？在这种情况下，“地址”是什么意思？
浏览 3提问于2013-06-26得票数 9
1回答
我一直试图将数据从SQL server (启用更改跟踪)加载到Kafka，以便一个或多个系统(报表、其他DB等)能够使用这些数据。我一直在寻找帮助回答以下问题的文档(找不到)
有人使用过D
浏览 0提问于2018-11-08得票数 2
我希望将一个4节点的Kafka集群迁移到一个新的集群，每个代理上有大约300 on的数据。问题是我们目前运行的是Cloudera的Kafka (CDK)，我们想运行Apache Kafka。在大多数情况下，CDK与Apache Kafka非常相似，但我正在尝试找出最好的迁移方法。我想知道我们是否可以启动一个新的Apache Kafka集群并将其添加到CDK集群中(如果有的话，还不确定这将如何工作)，然后一次一个地停止CDK服务器。否则，除了创建一个新的Apache <e
浏览 1提问于2019-10-22得票数 0
我已经克隆了存储库wurstmeister/kafka-docker，并从克隆它的文件夹中运行了-d。在这里之前一切都很好。我现在想走下一步.
我是否也需要一个kakfak连接映像，如果需要，如何做到这一点，我假设它在yml文件中？
浏览 2提问于2019-03-08得票数 0
因此，如果我在主机A，b，C，D和E上有5个经纪人，每个经纪人上都有一个Kafka和Zoo牧民实例，那么仅仅运行Kafka提供的动物园管理员就足够了吗？
浏览 8提问于2017-07-13得票数 7
回答已采纳
我需要在受控环境中测试我的kafka使用者和消息触发器。因此，我创建了一个ansible项目，用于创建一些模拟kafka服务器：。
它运作得很好，只是保安太糟糕了。默认情况下，playbook分出一个3节点的dockerized kafka集群，但是卡夫卡服务器上的侦听端口向所有用户公开。下面是用于创建集群的 of Dockerfile。但是，使用127.0.0.1:{{ port }}:{{ port }}公开端口只会向主机公开端口，如果我正确的话，不会将端口公开给其他容器。那么，我<
浏览 0提问于2016-02-04得票数 2
回答已采纳
Kafka版本: 0.10.2.1，org.apache.kafka.common.errors.TimeoutException: Expiring 10 record(
浏览 6提问于2017-10-15得票数 29
我需要从外部服务器读取带有.Net的Kafka消息。作为第一步，我在本地机器上安装了Kafka，然后编写了.Net代码。按要求起作用了。然后，我移到云端，但是代码不起作用。这是我的设置。我在Azure的Windows (VM1: 10.0.0.4)上部署了一个Kafka服务器。它已经开始运行了。我创建了一个测试主题，并使用cmd生成了一些消息。这两个VM都部署在同一个虚拟网络上，因此我不必担心打开端口或任何其他网络配置。
然后，我复制了Visual项目代码，然后将引导<
浏览 1提问于2021-05-28得票数 1
1回答
我正试图清理我的代码，并将models.py文件移到顶层，就像浮士德模块以外的其他模块现在将使用的那样。如果我从App目录运行服务器，它可以正常工作。但是，当我尝试运行以下代码来启动faust代理时，它也会从App目录返回一个No module named 'kafka.agent_a'错误：奇怪的是，当我从一个完全不同的目录运行相同的命令时，其中就有faust/<em
浏览 7提问于2021-12-30得票数 0
回答已采纳
1回答
我试图在我的Windows2012 R2超级v服务器上启用实时迁移，但它一直在失败。当我尝试使用GUI时，我会得到一个错误，上面写着“应用动态迁移更改时出错。修改服务设置失败”。ualizationOperationFailedException + FullyQualifiedErrorId : InvalidState，Microsoft.HyperV.PowerShell.VMTask:VMTask没有集群。
服务器之前有2012年，但是VMs迁<e
浏览 0提问于2016-11-27得票数 2
回答已采纳
我有一些检查，我每2小时做一次，以监视服务器的状态，如iostat -ch，df -h /DATA，free -mh，ps -aux | grep kafka和其他命令和一些外壳脚本。我如何将它们分组到一个或两个脚本中，以便自动执行它们，而不是每次都手动执行相同的检查？
浏览 15提问于2019-08-02得票数 0
如何将主板、管道、测试计划、工件和回购从本地azdevops服务器迁移到azdevops服务中的现有组织？它有没有其他可用的工具？
浏览 5提问于2021-11-12得票数 0
1回答
状态存储，计数存储，可能已经迁移到另一个实例。import org.apache.kafka.streams.KafkaStreams;import org.apache.kafka.streams.StreamsBuilder;
浏览 1提问于2019-04-03得票数 2
1回答
出于各种原因，我们想要迁移到kafka，想知道我们是否可以重新设计不使用memcached.的响应路径。
我正在试图了解什么才是解决以下问题的最佳实践系统设计。我们也在考虑从activemq切换到Kafka，因为这会给我们可重放的能力(但是我们没有卡夫卡的经验)。看一下Kafka，看起来就像要扫描整个分区所需要的特定消息，是否有更简单的方法来检索特定的消息？我们是否为每一个交互序列生成一个主题？
浏览 0提问于2019-07-29得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
