腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Apache
Kafka
配置
中
`
leader.imbalance.per.broker.percentage
`
的
含义
翻阅
kafka
文档,我发现了这个特殊
的
配置
。
leader.imbalance.per.broker.percentage
。直观地说,
leader.imbalance.per.broker.percentage
是什么意思?如何模拟此
配置
的
工作方式?
浏览 176
提问于2020-07-12
得票数 1
回答已采纳
1
回答
sed +替换文件
中
以包含键和值
的
长文本开头
的
键
、
、
、
在
kafka
.properies文件
中
log.retention.hours=12leader.imbalance.check.interval.seconds=300log.dir=/var/
kafka
/data1log.dir=/var
浏览 5
提问于2022-01-18
得票数 1
回答已采纳
1
回答
自动更改
kafka
主题分区引导符
我
的
Kafka
集群出了点问题。我有3个代理,所以当我停止代理1(例如)时,在副本
配置
中
,具有Lead1
的
每个主题分区都将其leader更改为seconde。所以这就是良好
的
行为,它工作得很好。/
kafka
-preferred-replica-election.sh --zookeeper myHost 因为当前
的
领导者是另一个复制品。所以我
的
问题是:有一种方法可以将
Kafka
配置
为自动执
浏览 0
提问于2018-06-05
得票数 5
1
回答
一旦主机被替换,卡夫卡复制品就不同步了。
、
、
你好卡夫卡/动物园管理员用户,卡夫卡
浏览 3
提问于2017-01-23
得票数 1
2
回答
Camel:检测
Kafka
错误IP
、
、
我正在将
Kafka
配置
为我
的
RouteBuilder
中
的
源码。我
的
目标是处理
Kafka
断开连接
的
问题。我
的
RouteBuilder如下: public void configure() { // will do more processing
浏览 2
提问于2017-11-14
得票数 2
1
回答
Kafka
连接器-错误处理程序
中
超出了容差
、
我有超过50个源连接器通过sql服务器,但其中两个是错误
的
,请告诉我可能是什么原因,因为我们有限制访问
kafka
服务器。(RetryWithToleranceOperator.java:104)\n\tat org.
apache
.
kafka
.connect.runtime.TransformationChain.apply:292)\n\tat org.
apache
.
kafka
.connect.runtime.WorkerSourceTask.execute(WorkerSourceTa
浏览 43
提问于2020-06-23
得票数 3
1
回答
如何访问数据源选项(例如
kafka
)?
、
、
我正在设置星火批处理选项从
Kafka
消费,但当我试图获得
配置
属性,它显示为无。为什么会这样?val df = sparkSession .format("org.
apache
.spark.sql.
kafka
010.KafkaSourceProvider") .option("
kafka
.bootstrap.servers", "
kafka
.brokers".getCon
浏览 4
提问于2019-10-26
得票数 1
回答已采纳
2
回答
无法在分布式模式下运行
Kafka
Connect -错误,同时试图创建/查找主题“连接-偏移”
、
,但不是已知
的
配置
。
中
的
(子)资源方法listConnectors包含空路径注释。警告: org.
apache
.
kafka
.connect.runtime.rest.resources.ConnectorsResource
中
的
(子)资源方法createConnector包含空路径注释警告: org.
apache
.
kafka
.connect.runtime.rest.resources.ConnectorPlugins
浏览 3
提问于2017-08-31
得票数 3
回答已采纳
1
回答
WSO2 EI611
Kafka
连接器错误jaas.conf未找到
、
、
、
、
带卡夫卡连接器
的
EI611最新抛出错误: 这个错误也是由其他人发布
的
:
浏览 0
提问于2017-10-20
得票数 0
1
回答
wso2入站端点-
Kafka
使用者
、
使用本文档,我将
配置
入站
Kafka
端点[2017-09-22 12:19:06,161] [] ERROR - KAFKAPollingConsumer Error
Kafka
Consumer Connector... 2017-09-22 12:19:08,152错误-在加载动物园管理员JAAS登录上下文'Client‘org.
apache
.
kafka
.common.KafkaException:异常时创建
Kafka
使用者Con
浏览 1
提问于2017-09-22
得票数 0
2
回答
SpringBoot
Kafka
:未加载“KafkaAutoConfiguration”
中
的
Bean方法“kafkaTemplate”
、
、
、
、
我正在使用springboot并尝试编写一个KafkaProducer来推送
Kafka
队列
中
的
消息。我在@Configuration类
中
创建了这些方法。configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress); //bootstrapAddress holds address of
kafka
类
中
自动连接了这个KafkaTemplate bean,它负责处理KafkaTempl
浏览 3
提问于2020-09-09
得票数 0
1
回答
Spark结构流
的
源/目标格式
的
可用选项
、
、
、
当我们在Spark
中
为格式使用DataStreamReader API时,我们使用option/options方法为所使用
的
格式指定选项。例如,在下面的代码
中
,我使用
Kafka
作为源,并通过option方法传递源所需
的
配置
。在这里,我只使用了两个选项- server details and topic configuration。我试图找出
的
是,对于特定格式
的
数据源或接收器,有哪些其他选项可用,在本例
中
为
Kafka<
浏览 22
提问于2021-11-14
得票数 0
1
回答
在ElasticSearch中将主题键映射为文档id
的
Kafka
连接器
、
、
正如在下面的示例中提到
的
,我希望将"AKA-25“键作为文档id,但是我正在做
的
转换失败了。如果我从值中提取任何其他字段,就像我尝试使用"empId“一样,它似乎工作得很好。但我
的
要求是映射钥匙。这里是连接器
配置
: "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector", "key.converter&
浏览 1
提问于2021-03-10
得票数 2
1
回答
Kafka
未捕获异常
、
、
当生产者发布第一条消息时,我得到了以下异常,我试图理解这个错误
的
含义
Uncaught exception in thread '
kafka
-producer-network-thread | producer(Sender.java:596) ~[
kafka
-clients-2.3.1.jar:na] at org.
apache
.
kafka
.clients.producer.internals.Sender.access$100(Sender.java:74) ~[<
浏览 82
提问于2020-08-26
得票数 1
回答已采纳
1
回答
找不到类org/
apache
/zookeeper/server/NIOServerCnxn$Factory
、
、
、
、
我们最近在J2EE应用程序
中
添加了
Kafka
用法,但是在glassfish启动(初始化)过程中出现以下错误:看看之前
的
,它建议降低zookeeper
的
版本,然而我
的
项目并没有直接控制zookeeper
的
版本(据
浏览 2
提问于2015-11-24
得票数 0
1
回答
wso2 esb
中
的
Kafka
生产者超时
、
在启用了sasl
的
Kafka
2.11和wso2 ESB6.2
中
,我们得到了下面的异常。wso2 esb和
Kafka
clsuter
中
的
SASL机制是PALIN,但在日志中看到错误2。错误1: TESTTOPIC: org.
apache
.
kafka
.common.errors.TimeoutException:过期1条记录
的
错误1: java.util.concurrent.ExecutionException自批量创建以来已过300
浏览 946
提问于2019-11-06
得票数 1
5
回答
如何
配置
Kafka
生产者
的
日志?
、
、
、
我使用
的
是
Kafka
producer客户端,我
的
项目中没有任何log4j
配置
。log4j.rootLogger=ERROR 如何更改
Kafka
日志级别?
浏览 3
提问于2016-03-03
得票数 21
2
回答
Log4j2 -为包设置日志级别,然后设置子包
、
、
、
所以,我想在调试时有自己
的
代码,但是
Apache
在警告。除了卡夫卡(
Kafka
),它产生了太多
的
警告,所以我尝试了如下:log4j.logger.org.
apache
=WARN但是log4j.logger.org.
apache
.
kafka
.common.config=ERROR doen似乎什么也不做,因为我仍然得到了大量
的
日志语句,比如 2017-12-20T14:31
浏览 3
提问于2017-12-20
得票数 3
回答已采纳
1
回答
在融合云上连接扫雪机和
Kafka
的
问题
、
、
、
、
在使用Helm在Kubernetes
中
构建工作
的
登台环境之前,我想尝试将Scala Stream
Kafka
收集器连接到我们
的
Kafka
Confluent Cloud帐户。这是我
的
config.hocon
配置
- enabled =
kafka
retriesour-confluent-api-secret';
浏览 101
提问于2021-03-10
得票数 0
1
回答
如何在Storm Flux
中
配置
通用参数
、
我是Storm Flux上
的
新手,现在对如何在Storm Flux
中
配置
通用参数感到困惑。例如,org.
apache
.storm.
kafka
.spourt.KafkaSpout
的
定义如下: c
浏览 7
提问于2018-05-29
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Kafka的安装与配置(一)
Apache Kafka的安装与配置(二)
“Kafka技术”Apache Kafka中的事务
“事件驱动架构”Apache Kafka中的事务
“消息中间件”Apache Kafka中的事务
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券