我们使用的是debezium源连接器。在向kafka生成消息时，acks1，0的默认值是多少？生产者的配置- https://docs.confluent.io/current/installation/configuration/producer-configs.html#acks
浏览 36提问于2020-07-03得票数 0
我正在尝试写一个独立的java程序使用kafka-jdbc-connect API来流式传输数据从oracle-table到kafka主题。使用的接口:我目前正在尝试使用Kafka连接器，准确地说是JdbcSourceConnector类。我所做的:创建一个JdbcSourceConnector.java类的实例，并通过提供Properties对象作为参数来调用该类的start(Properties)方法。启动线程后，无法读取&quo
浏览 3提问于2019-06-12得票数 0
我尝试使用这个Kafka连接器: com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector在Kafka集群上公开我没有看到任何关于Acks 的参数[2022-02-03 16:03:46,551] INFO ProducerConfig values:
acks =我试图在我的配置中设置ack=1，但它似乎不起作用
浏览 8提问于2022-02-03得票数 0
是否可以通过filebeat.yml文件中文件节拍使用输出作为output.azure，并从本地文件输入，或者我们需要Kafka作为输出以将日志注入到eventhub azure。据我所知，只有我能看到kafka模块作为输出模块，用于将日志发送到Azure EventHub 和存储帐户是必要的，即使是注射?？ 谢谢!
浏览 82提问于2021-10-26得票数 0
我在AWS中有一个正在运行的debezium集群，没有问题。我想尝试一下AWS MSK。所以我启动了一个集群。然后我启动了一个EC2来运行我的连接器。然后安装confluent-kafka sudo apt-get update && sudo apt-get install confluent-platform-2.12 默认情况下，AWS MSK",
"value.converter": "org.apache.kafka.<em
浏览 128提问于2019-12-20得票数 7
回答已采纳
解释：我想要做的是使用docker将卡夫卡主题数据写入redis。他们创建了一个自述文件来指导如何设置kafka的配置： "name" : "RedisSinkConnector1",
"connector.class" : "com.
浏览 0提问于2019-09-15得票数 1
回答已采纳
下面是我的Kafka-MQTT接收器连接器配置 name=anonymousconnector.class=tcp://127.0.0.1:1883 at org.apache.kafka</e
浏览 32提问于2021-07-23得票数 0
回答已采纳
源进程由使用source Connect Api的管理，并使用扩展Confluent Connect docker镜像的Mesos (DC/OS)部署在我们的系统上。Kafka本身使用框架版本部署在相同的DC/OS上。由于我们有一些大于默认大小的消息，我已经更改了这些kafka安装参数：·message.max.bytes
两者均为4MB。=41
浏览 0提问于2017-10-09得票数 3
需要帮助理解Kafka中的'acks‘属性，该属性在生产者配置中。 假设我错过了在producer类中传递'acks‘属性。然后，默认情况下，Kafka认为它是‘ack =0’。现在假设我需要有'acks=all‘，这样它才能保证我的消息传递到Kafka broker。有没有什么方法可以确保server.properties文件中的任何设置都是默认的‘
浏览 8提问于2019-09-19得票数 1
我只能修改connect-distributed.sh以启用更改。任何指针都是一个很好的补充。对kafka-run-class.sh进行了修改，使jmx_exporter能够在http://<host>:9304/metrics上发出jmx指标。
浏览 0提问于2019-07-01得票数 1
我正在使用Kafka集群和Debezium MySql连接器从数据库更新到Elasticsearch中获取消息。有一段时间，我在做一些测试，最后得到了一个混合的ES，所以我想对Elasticsearch做一个新的满负荷测试。此时，我将手动删除连接器和创建的主题并重新创建它们，这样它就可以像最初那样加载，但是对于如何在正确的步骤中执行这个清理过程有任何想法吗？
浏览 5提问于2020-04-07得票数 3
我正在设计一个MySQL -> Debezium -> Kafka -> Flink -> Kafka -> Kafka Connect JDBC -> MySQL。下面是我在Flink上写的示例消息(我也尝试过使用Kafka控制台生产者) { "type": "struct", {at org
浏览 70提问于2019-02-27得票数 0
回答已采纳
2回答
为了测试的目的，并找出我的确切错误，我没有使用我的访问密钥和秘密访问密钥的秘密。由于错误，我的舵图失败了：Error: releaseloping-grizzly failed: Deployment.apps "kafka-connect" is invalid: s
浏览 0提问于2018-10-22得票数 4
回答已采纳
1回答
在不启用SASL或SSL的情况下，我成功地连接了GCS连接器。当我启用SASL和SSL时，连接独立似乎无法与代理进行通信。- 19091:19091 KAFKA_BROKER_ID: 1 KAFKA_ADVERTISED_LISTENERS/secre
浏览 0提问于2018-12-19得票数 0
回答已采纳
卡夫卡连接开始时(例如在汇合平台)，是否有自动加载(多个) Kafka连接连接器的方法？到目前为止我发现的是：是否还有另一种方法，例如，将所有的连接器都包含在“Connect -独立的\\Distributed.properties”文件中(类似于在KSQL -server.properties中提供ksql查询文件)，以便
浏览 2提问于2019-06-06得票数 5
我正在工作赢得了一个涉及卡夫卡连接的项目。我们有一个运行在Kubernetes上的Kafka Connect集群，一些Snowflake连接器已经启动并工作。我们现在遇到的问题是试图从Kafka Connect集群中获取JMX指标以在Datadog中报告。根据我对文档(https://docs.confluent.io/home/connect/monitoring.html#using-jmx-to-
浏览 40提问于2021-07-08得票数 0
1回答
我有一个接口程序-E29，其中我运行了动物园管理员、Kafka、Kafka Connect和KafDrop，问题是，当我在本地运行时，我可以从我的Spring Boot<code>E 29</code>我需要的是在Linux机器上运行相同的配置，并能够以同样的方式从Spring应用程序连接。: kafka:29092networks: driv
浏览 1提问于2020-12-07得票数 3
我使用的对接图像是confluentinc/cp-kafka:latest。它需要KAFKA_ADVERTISED_LISTENERS环境变量，它允许卡夫卡客户端与代理进行通信。如果我使用localhost作为这个值，它只在本地的Kafka broker pod中工作，但是对于kubernetes集群中的某些Kafka客户端荚无法与它通信。如果我使用的是来自kubectl get endpoints -l app=k
浏览 1提问于2018-04-29得票数 3
3回答
我已经成功地使用发布的融合图像设置了Zookeeper和Kafka，请参阅以下docker-compose文件： zookeeper: image: confluentinc/cp-kafka-connect:3.2.0 depends_on:}:9092，我已经成功地将Kafka容器正确地
浏览 0提问于2017-03-27得票数 19
我主要想做的是使用Docker Compose拥有多个Kafka Connect实例。我想让ksqlDB使用这个集群。目前，它们都在一台机器上运行，但最终我希望将其部署到多节点环境中。我的问题是ksqlDB显然找不到Kafka Connect集群。还有KSQL_KSQL_CONNECT_URL，代表单个Kafka Connect实例的URL。如果不提供此变量，则会产生默认值，即lo
浏览 5提问于2021-05-13得票数 0
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
