腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Kafka
Admin
:如
何以
编程
方式
显示
和
设置
每个
主题
的
保留
时间
?
我正在尝试以
编程
方式
(Java)获取
和
设置
Kafka
集群中某组
主题
的
保留
时间
。 使用org.apache.
kafka
.clients.
admin
.AdminClient似乎是不可能
的
。
浏览 17
提问于2019-02-21
得票数 0
1
回答
删除
主题
后
的
代理磁盘使用情况
、
我将巨大
的
dbs转储到
Kafka
中,其中
每个
数据库
的
表都是一个
主题
。 在
主题
完全被消耗之前,我不能删除它。我不能
设置
基于
时间
的
保留
策略,因为我不知道什么时候会使用
主题
。我
的
磁盘和数据太多了。我必须以
编程
的
方式
编写代码,通过消耗
和
删除来编排。我理解问题
的
出现是因为我们使用
Kafka</e
浏览 1
提问于2018-08-14
得票数 1
回答已采纳
3
回答
设置
配置retention.ms=3600000仍未删除卡夫卡
的
数据
、
我已经通过以下命令
设置
了retention.ms=3600000,但1小时后磁盘上仍然有大量数据。由于卡夫卡
的
大量数据,我
的
磁盘已经满了。 ./bin/
kafka
-topics.sh --zookeeper zookeeper:2181 --alter --topic topic_1 --config retention.ms=3600000/bin/
kafka
-topics.sh --zookeeper zookeeper:2181 --describe --to
浏览 0
提问于2018-11-15
得票数 1
回答已采纳
1
回答
如何查找
每个
主题
的
保留
字节数
我们可以使用以下
kafka
config命令将
保留
字节数
设置
为1000000 TOPIC_NAME=test
kafka
-configs --alter --zookeeper localhost:2181 --entity-type topics --entity-name $TOPIC_NAME --add-config retention.bytes=1000000 但是如
何以
相反
的
方式
找到
每个
主题
的
<e
浏览 10
提问于2021-01-25
得票数 0
回答已采纳
2
回答
在confluent-
kafka
-python中
设置
主题
日志
保留
、
、
我在文档中找不到如何在使用confluent-
kafka
创建生产者时
设置
保留
时间
。 如果我只指定'bootstrap-servers‘,默认
保留
时间
是1天。我希望能够改变这一点。
浏览 0
提问于2017-05-18
得票数 2
2
回答
server.properties中
每个
主题
的
Kafka
日志
保留
时间
、
我想降低其中一个
Kafka
主题
的
保留
期。我希望其余
的
主题
仍然使用默认
的
保留
时间
(7天)。我知道我们可以通过终端进行
设置
:bin/
kafka
-topics.sh --zookeeper XXX --alter --topic XXXX --config retention.ms=86400000我想知道是否有一种方法可以做到这一点,这样它就可以在server.properties中
设
浏览 0
提问于2017-11-15
得票数 2
2
回答
在drupal中以
编程
方式
更改管理
主题
、
如
何以
编程
方式
设置
我
的
管理
主题
?现在我想我
的
管理
主题
为魔术。我尝试将其从/
admin
/settings/
admin
更改,但没有效果。 有没有办法做到这一点?我想为我
的
网站前端<em
浏览 3
提问于2012-06-01
得票数 3
1
回答
在重新启动群集时,将删除连接使用者作业。
、
我面临以下问题:改变一些与
kafka
相关
的
属性,并重新启动集群。因为它将从下面的系统
主题
获取元数据信息。
浏览 1
提问于2017-06-22
得票数 2
回答已采纳
2
回答
具有不同
保留
性
的
Kafka
主题
,尽管具有相同
的
配置
、
我有一个关于
保留
主题
信息
的
问题。我有以下情况:请描述这两个
主题
中
的
每个
主题
的
命令:问题是: 怎样才能让
主题</e
浏览 2
提问于2020-07-27
得票数 2
2
回答
在
kafka
上获取java.nio.file.AccessDeniedException
、
我试着在windows上
设置
kafka
和
zookeeper。最初,我创建了
主题
、生产者
和
消费者。它工作得很好。然后我使用下面的命令删除了一个
主题
:现在,每次我重新运行
kafka
时,它都会终止,并
显示
以下错误: C:\
kafka<
浏览 3
提问于2021-05-16
得票数 3
1
回答
动态
编程
主题
名称/ Quarkus Smallrye反应式消息
Kafka
、
、
、
、
我想使用这个扩展: Quarkus Smallrye Reactive Messaging
Kafka
但是在我
的
应用程序中,
主题
的
名称是事先不知道
的
,它是根据在运行时从用户收到
的
消息来指定
的
。如
何以
编程
方式
在没有注释
的
情况下指定与
主题
相关
的
主题
名称
和
设置
?(仅用于向
Kafka
-> P
浏览 20
提问于2021-02-18
得票数 2
7
回答
如何使用Python在Apache
Kafka
中以
编程
方式
创建
主题
、
、
、
到目前为止,我还没有看到一个python客户端可以显式地实现
主题
的
创建,而不使用配置选项自动创建
主题
。
浏览 1
提问于2014-09-25
得票数 40
2
回答
如何从
kafka
中强制删除
主题
为了删除
主题
- hgpo.llo.prmt.processed,我们执行以下步骤注意-我们
设置
- delete.topic.enable"
kafka
01
kafka
-logs]# /usr/hdp/current/
kafka
-broker/bin/
ka
浏览 1
提问于2017-12-01
得票数 2
回答已采纳
6
回答
Kafka
对实时数据
的
主要优势是什么?
、
在我们
的
大数据时代,您
的
IT基础架构可能会受到各种来源数据涌入
的
影响。最重要
的
是,客户要求“实时”查看他们
的
数据,没有任何延迟
时间
,因此您
的
服务器需要快速处理
和
显示
数据。
Kafka
是一个分布式流媒体平台,使公司能够创建实时数据源。Uber,Twitter,Airbnb,Yelp以及今天财富500强公司中超过30%
的
公司都在使用它。例如,通过集成各种数据,
如
喜欢,页面点击,搜索,订单
浏览 7055
提问于2018-09-14
2
回答
Apache
、
、
我正在学习Apache
Kafka
(作为一种消息传递系统),在这个过程中,我了解了术语StateStore,有人能帮我理解这件事吗。
浏览 3
提问于2019-12-28
得票数 1
1
回答
基于消息消费
的
kafka
自动删除
就像我们在MQ解决方案中一样,消息一旦被使用,是否可以在
Kafka
中自动删除? 由于我无法控制何时使用消息,因此无法按
时间
/字节大小定义
保留
时间
浏览 0
提问于2021-06-30
得票数 0
1
回答
如何让
kafka
根据提供
的
保留
时间
删除日志
、
、
=300000 log.retention.hours最初像往常一样
设置
为168,但我认为这可能是一个足够长
的
时间
,因为我在具有30GiB磁盘存储
的
t2小型机上运行这段
时间
,所以我将
保留
小时数减少到24我在
主题
上运行了describe,以查看
主题
是否有更大
的
保留
策略,我认为这可能会覆盖server.properties文件,但在运行
kafka
-topics.sh --zookeeper localh
浏览 0
提问于2020-08-11
得票数 0
3
回答
如何制作
kafka
主题
的
非重复数据删除版本
如果我在
kafka
中有一个
主题
,其中包含使用整数作为键
的
消息。如何创建一个基于该
主题
但没有重复
的
主题
,并且消息按其键排序?例如,假设
主题
名称为"my_topic",该
主题
中有5条消息:key: "13", value: "{ value: 40 }" key"{ value:
浏览 0
提问于2019-03-14
得票数 0
2
回答
将
kafka
用于CQRS
我读了很多关于
kafka
用作活动商店
和
CQRS
的
潜在候选者
的
文章。我想知道,由于
kafka
中
的
消息有一个有限
的
保留
时间
,那么消息从
kafka
保留
消息
的
磁盘中删除后,事件将如何重播?从逻辑上讲,当这些消息从
kafka
外部(在读取
kafka
主题
的
消息之后)存储在数据库(sql/nosql)中时,从事件存储
浏览 3
提问于2019-11-16
得票数 0
1
回答
Wso2 CEP中
的
执行计划模板
、
我正在使用
Kafka
CEP来处理来自WSO2
主题
的
事件。我想将其推广到多个
kafka
主题
,它们以类似的格式存储日志,即
每个
主题
的
每个
分区存储特定人
的
数据。场景如下;一个
主题
表示一个超级组,其中
每个
分区都是该组中
的
一个人。在
每个
分区中,存在该人
的
JSON格式数据点{银行交易信息(交易
时间
、贷方/借方、
浏览 4
提问于2016-06-29
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka的简单介绍
为什么BAT互联网都爱用kafka?看完你就知道了
Kafka之安装部署
Kafka权威指南(一):初识Kafka
深入理解Kafka Connect:转换器和序列化
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券