如何在配置了confluent kafka docker-compose的机器上保持所有设置的配置？

文章/答案/技术大牛

发布

1回答

docker、apache-kafka、ksqldb

这是我用于kafka和ksqldb设置的docker-compose文件， ---services: image: confluentinc作为宿连接器，我使用ksqldb进行所有转换，以下是我在ksqldb中运行的命令。= 'earliest'; CREATE SINK CONNECTOR `sink_elasticsearch` WITH (<

浏览 19提问于2021-08-12得票数 0

回答已采纳

1回答

如何配置停靠-组合，以便将磁盘挂载到文件夹，而不是本地磁盘上

docker、apache-kafka、docker-compose

我们在Docker上使用单节点基本部署，包括以下服务schemaregistry示例： Name/docker/run Up 0.0.0.0:9021->9021/tcp kafka-single-node_kafka_1 /etc/confluent/docker我们在ka

浏览 4提问于2019-11-05得票数 1

回答已采纳

2回答

用于许可证主题的Kafka连接复制因子

docker、apache-kafka、apache-kafka-connect、confluent-platform

我正在尝试使用Kafka-Connect在本地运行docker-compose。虽然我非常喜欢汇合的产品和卡夫卡，它有时是一个巨大的要求，通过一些配置或找到一个一致的例子。在我的docker文件中，我现在正在为broker、zk、sr和kafka-connect使用broker版本，但我也尝试了较早的版本。代理(confluentinc/cp-server:6.0.0)在以下方面失败： Broker 1上

浏览 3提问于2020-11-02得票数 1

回答已采纳

1回答

ConnectException:连接被拒绝卡夫卡生产者

kubernetes、apache-kafka、kubernetes-helm

我已经使用Helm和Minikube部署了Kafka。我需要建立一个生产者在Scala的代理IP地址和主机是必需的。我已经定义了NodePort服务来向外部世界公开Kafka。我将代理设置为minkube-ip:service-node-port，但是，我得到了连接异常。我定义的配置有什么问题？有了docker-compose文件，应用程序就能正常工作。Avro message Caused by:

浏览 54提问于2019-01-22得票数 0

回答已采纳

1回答

Aerospike源连接器

apache-kafka、apache-kafka-connect、confluent-platform、aerospike

我已经使用Kafka的confluent本地集群为Kakfa和m设置了所有所需的配置，并安装了https://www.confluent.io/hub/aerospike/kafka-connect-aerospike-source并启动了confluent集群，但连接器仍然没有启动另外，我发现confluent的</em

浏览 11提问于2021-08-10得票数 1

1回答

卡夫卡机器重新启动后如何保留卡夫卡保留和卡夫卡保留段

apache-kafka、apache-zookeeper

我们将retention bytes值- 104857600设置为主题- topic_test机器启动和kafka服务成功启动后，我们再次检查了动物园管理员的retention-bytes：但是现在(在机器重新启动之后)，我们可以看到retention

浏览 2提问于2020-07-22得票数 2

回答已采纳

1回答

合流控制中心不显示系统健康状况(用于多集群配置)

docker、apache-kafka、confluent-platform

使用下面的docker映像=confluentinc/设置了一个3节点的kafka集群。在另一台机器上，我下载了confluent平台v5.0.1，并配置(尝试)控制中心来监视码头集群。用于控制中心配置的kafka broker与下载的configuration v5.0.1相同(我通过bin/confluent启动整个堆栈)

浏览 0提问于2018-12-15得票数 0

1回答

融合云上kafka集群的变更代理配置

apache-kafka、confluent-platform

我在一个项目中使用kafka，具体来说，我使用的是合流云的托管kafka。我需要更新我的代理配置(特别是字段offsets.retention.minutes)，但我在的时候有点不知所措--应该怎么做。但代理命令不起作用)，当我传递汇流云UI中提供的默认REST URL时，该工具失败了。我在网上看到了有关登录到代理和手动更改server.properties文件以包括我的配置和手动重新启动服务器<e

浏览 9提问于2022-11-30得票数 0

回答已采纳

1回答

如何读取文件夹中的文本文件并在windows上写入Kafka主题

python、apache-kafka

我有一个本地设置卡夫卡在我的windows 10机器。目前，我仍然在学习卡夫卡，并在我的本地机器上测试它的能力。.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test 现在，我试图将在网络文件夹中生成的文本文件的内容流到<

浏览 5提问于2021-05-05得票数 0

回答已采纳

1回答

关闭Kafka* Exporter Config中自动启用的Confluent遥测指标？*

kubernetes、apache-kafka、confluent-platform、kubernetes-operator

由于某些原因，_confluent_telemetry_metrics会自动启用。即使使用telemetry.enabled=false关闭了Confluent遥测报表程序，也会发生这种情况。这是我笔记本电脑上的Confluent Operator和Kubernetes (Confluent Platform v6.0)。topic.partitions = 12 topic.replicas = 3 这导致了大量的错误，因为

浏览 46提问于2020-12-02得票数 1

1回答

如何在默认情况下使用，以及如何使用由汇合API生成的Kafka消息？

java、spring、apache-kafka、spring-cloud-stream

我正在构建一个微服务组件，默认情况下，它将消耗由其他组件(SCS)生成的Stream (SCS) Kafka消息。这是下面使用SCS输入绑定和汇合输入绑定的应用程序配置。如果删除上述配置中的注释，则两个使用者都将从我的汇合客户端发送配置，例

浏览 0提问于2018-08-08得票数 5

回答已采纳

2回答

信息中心&合流卡夫卡连接S3

message-hub

我需要在中使用来自MHub主题的消息。有可能吗？

浏览 2提问于2018-09-19得票数 1

回答已采纳

2回答

confluent_kafka用户偏移计数重置问题

python、apache-kafka、kafka-consumer-api、confluent-platform

描述docker-compose -f docker-compose-single-broker.yml rm 为了删除我用来测试的</

浏览 0提问于2018-09-25得票数 1

1回答

如何为合流模式注册表配置主题命名策略？

apache-kafka、avro、confluent-schema-registry

显然，可以重写这一点，并将主题命名策略设置为RecordNameStrategy或TopicRecordNameStrategy。不幸的是，文档并不十分清楚主题命名策略如何或在何处可以被覆盖。因此，您现在可以选择使用confluent.key.subject.name.strategy和confluent.value.subject.name.strategy将模式主题键和值配置为默认的命名策略而不是默认的命名策略/bin/kafka</e

浏览 11提问于2020-10-31得票数 2

回答已采纳

2回答

无法启动合流模式注册表

apache-kafka、confluent-platform、confluent-schema-registry

我已经在Ubuntu16.04机器上安装了汇合平台，最初我已经配置了动物园管理员、Kafka和ksql，并启动了合流平台。我能看到下面的信息。is [UP] control-center is [UP]Cause

浏览 2提问于2019-01-30得票数 5

1回答

合流模式注册表SSL配置

ssl、apache-kafka、confluent-platform、confluent-schema-registry、apache-kafka-security

我是卡夫卡领域的新手。然后我配置了属性文件。我的(汇流平台安装dir) /etc/kafka/server.propert

浏览 2提问于2020-02-20得票数 0

1回答

如何从容器外部调优/编辑/添加/更改kafka对接器容器参数

docker、apache-kafka

我们有kafka码头容器如下(在Linux 7.5上) Name Command State: 1 我们希望控制kafka码头容器配置--从容器(或操作系统本身)到外部的/etc/kafka/server.properties

浏览 1提问于2019-11-05得票数 3

回答已采纳

2回答

如何使用JDBC接收器连接器将表名转换为大写

oracle、jdbc、apache-kafka-connect、confluent-platform、debezium

我正在实现基于CDC的Postgres和Oracle数据库之间的复制。对于源连接器，我使用的是Debezium的Postgres连接器和汇连接器--Confluent的JDBC sink连接器。在Postgres数据库中，所有表都是用小写创建的，但在Oracle数据库中，表是大写的。如何在JDBC接收器连接器中动态设置配置，以便不需要在transforms.route.replac

浏览 5提问于2021-04-01得票数 1

1回答

在kafka集群上启用ssl时，kafka-connect启动失败

ssl、apache-kafka、apache-kafka-connect、confluent-platform

我正在尝试评估kafka confluent platform 4.0版。但是，当我在kafka集群上启用ssl时，kafka-connect启动失败。详细的日志记录如下： [2017-12-18 04:38:55,747] ERROR Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder70)

浏览 88提问于2017-12-18得票数 1

1回答

Kafka confluent 4.1.1重新启动问题--先前创建的主题未显示

apache-kafka、confluent-platform

我使用的是kafka confluent-4.1.1。我创建了几个主题，而且效果很好。如果我重启confluent，我看不到之前创建的主题。但没那么走运。有没有人面临同样的问题？我需要更改任何配置吗？提前谢谢。

浏览 0提问于2018-06-29得票数 0

点击加载更多