我们已经为Kafka在IBM数据复制CDC复制引擎上建立了工作订阅。消息(复制的事务)开始出现在目标kafka主题上。我们的目标是创建一个程序，它从kafka读取这些消息并写入目标系统上的文件。
“……将系统参数kafka_bookmark_storage_type从默认值POINTBASE更改为COMMITSTREAMTOPIC值.“。
请你告诉我
浏览 6提问于2019-11-12得票数 1
我创办了zkper和kafka。然后我尝试运行consumer，得到了这个错误。@erjancomputer MINGW64 /c/kafka_2.12-2.8.0/bin/windows at kafka.utils.Logging.$init$(Logging.scala:47)
at <e
浏览 262提问于2021-09-12得票数 0
回答已采纳
我有一个非常大的文件，需要作为环境变量传递给linux ec2平台中的Docker run命令。="/" -d obsidiandynamics/kafdrop I get /bin/docker :参数列表太长 因此，我没有执行上述操作，而是传递了文件kafdrop中的所有环境变量-properties文件如下所示： KAFKA_BROKERCONNECT=host:port
KAFKA_TRUSTSTORE="$(cat 2kafka</em
浏览 41提问于2020-11-04得票数 0
_64-2.7 copying confluent_kafka/__init__.py -> build/lib.linux-x86_64-2.7/confluent_kafka
creating build/lib.linux-x86_64-2.7/confluent_kafk
浏览 4提问于2016-10-30得票数 0
回答已采纳
1回答
我想知道如何验证与kafka的连接:让我更好地解释：这是一段代码：for msg in consumer:getaddrinfo failed for kafka:9092, exception was [Errno -2] Name or service not know
浏览 1提问于2018-01-14得票数 0
我正在做一个项目，该项目要求我使用dotnet和Confluent库连接到现有的Kafka集群。Kafka群集使用Kerberous/Keytab身份验证。那么，我如何指定密钥表文件，以便可以针对Kafka集群进行身份验证？
浏览 15提问于2019-05-31得票数 2
以下是步骤kafka-secure2:/usr/src$ uname -a
kafka-secure2:/usr/src$ find ./linux-headers-4.1
浏览 0提问于2019-06-28得票数 -1
我有一个运行apache kafka 2.2.1的安全MSK集群。如果我在私有子网(amazon linux 2)中创建了一个ec2实例，并安装了java和kafka，则可以执行以下操作来与kafka通信：ssl.truststore.location=/tmp/kafka.client.truststore.jks
并在--comm
浏览 32提问于2020-05-15得票数 1
2回答
我有一个带有三个节点的kafka 0.11.xx服务器。服务器所在的机器是具有4 4GB的linux Ubuntu机器。我可以看到java进程占用了大约90%的内存。我已经将堆的值设置为5 5GB。那么，这是一个正常的情况下，kafka预计运行与4-5 GB的内存，或这是一些不正常的东西。
如果这不是通常的情况，你可以为这个问题提出一个解决方案，或者增加RAM将是唯一的解决方案。
浏览 474提问于2018-10-03得票数 1
1回答
--listdocker exec kafka1 kafka-topics(仍然来自Linux控制台)现在，我正在以与上面相同的方式创建第二个独立集群：创建 Linux 主题：
docker exec kafka1 kafka-topics--bo
浏览 6提问于2022-11-06得票数 0
我正在关注(至少尝试)这个卡夫卡快速入门文档Kafka quickstart 在执行Kafka和Zookeeper服务器启动时，它们都会导致以下错误： [0.003s][error][logging]Error opening log file '/c/Users/Manol/Downloads/kafka_2.13-2.7.0/kafka_2.13-2.7.0/bin/..No such file or directory
[0.
浏览 54提问于2021-03-06得票数 2
我们在kafka机器上创建主题，并打算将数据注入主题分区。但是问题是-应该设置哪个坞配置文件/s和参数？我们使用的是docker-compose.yml，其中包含了卡夫卡的以下部分
kafka
浏览 4提问于2019-11-05得票数 1
回答已采纳
/x86_64-linux-gnu/librdkafka.a(rdkafka_broker.o): In function `rd_kafka_broker_thread_main':(.text+0x9d06/x86_64-linux
浏览 5提问于2019-09-24得票数 2
回答已采纳
我寻找了这个问题的解决方案，但只有一些临时的修复方法，比如更改server.properties中的日志目录位置。几天后，错误就会悄悄出现在你身上。我的应用程序是连续运行的，所以有什么永久的修复方法吗？
浏览 3提问于2020-09-09得票数 0
直到30分钟前，Kafka对我来说还很好。我使用的是windows，我使用的命令是：启动zookeeper然后启动kafka服务器。
现在，由于某些原因，zookeeper无法工作。也就是
浏览 7提问于2020-08-28得票数 1
2回答
文件夹中的流式文件
、、、
我要把流媒体应用从flume转移到kafka。我有一台windows机器，在其上，由物联网传感器在特定位置(例如D:/Folder )连续生成CSV文件。1)在传输日志文件之间是否需要kafka集群/代理，或者是否可以直接从windows机器传输到hadoop linux机器？2)是否可以在windows和hadoop linux机器上安装kafka，然后将CSV文件直接发布到hadoop机器上创建的kafka topic。
我将在
浏览 4提问于2017-12-26得票数 0
1回答
忽略librd中的测试
、、、
/x86_64-alpine-linux-musl/bin/ld: /go/pkg/mod/gopkg.in/confluentinc/confluent-kafka-go.v1@v1.4.2/kafka/librdkafka/librdkafka_glibc_linux.a(rdkafka_mock_cgrp.o): in function `rd_kafka_mock_cgrp_me
浏览 62提问于2020-08-26得票数 3
我有一个作为linux容器的nodejs应用程序，它使用了kafka节点库。Kafka在运行windows的主机上运行：我使用以下命令运行nodejs容器：为了连接主机的kafka，我使用以下命令：
client = new kafka.KafkaClient({kafkaHost: "loc
浏览 3提问于2020-01-17得票数 0
我只是用buildx制作了multarch图像错误消息------
> [linux/arm64 3/5] RUN curl "https://archive.apache.org/dist/kafka/2.8.0&#x
浏览 12提问于2021-09-21得票数 7
2回答
如何从Linux上的文件中删除最后一个逗号分隔符？文件示例："kafka_log_dir" : "/var/log/kafka","kafka
浏览 0提问于2018-06-03得票数 9
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
