从客户端检索 Kafka 代理属性

2023-12-19

我想知道是否有一种方法可以使用 shell 命令检索 kafka 代理的所有配置属性?

例如,类似的东西:

./kafka-configs.sh --zookeeper ${broker_ip}:2181 --entity-type brokers --describe

上面的内容没有返回任何值,但我希望通过命令可以更清楚地了解问题


您可以在 Kafka Broker 的日志文件中找到该配置,该日志文件在 Broker 启动时打印。恐怕有这样的命令列出了 Kafka Broker 的所有配置参数。

可以通过 Zookeeper 检索有关 Kafka 代理的更多信息(但是这些命令不会为您提供 kafka 配置)。为此,

进入Zookeeper shell:

zookeeper-shell localhost:2181

and run

get /brokers/ids/0

检索具有 id 的经纪人的更多信息0.

EDIT:

虽然kafka-configs声称能够描述kafka配置、命令

kafka-configs --bootstrap-server localhost:9092 --describe --entity-type brokers --entity-name 0
Configs for broker 0 are:

似乎没有返回任何配置参数。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

从客户端检索 Kafka 代理属性 的相关文章

  • 使用 Kafka Streams 进行 OpenTracing - 如何?

    我正在尝试将 Jaeger 跟踪集成到 K Streams 中 我计划将跟踪添加到几个最重要的管道中 并且想知道将 Traceid 从一个管道传递到另一个管道的好方法是什么 这是我到目前为止所做的 在流处理管道开始时 我启动一个服务器范围并
  • python 脚本在 docker 内运行时无法导入 kafka 库 [重复]

    这个问题在这里已经有答案了 我有以下 python 脚本 可以从 twitter 中提取推文并将其发送到 kafka 主题 该脚本运行完美 但是当我尝试在 docker 容器内运行它时 它无法导入 kafka 库 它说 语法错误 语法无效
  • 卡夫卡高级消费者 error_code=15

    当尝试使用高级消费者 使用全新的消费者组 从 Kafka 进行消费时 消费者永远不会开始运行 当我将日志记录级别切换为调试时 我可以看到以下两行一遍又一遍地重复 DEBUG AbstractCoordinator 09 43 51 192
  • 如何使用不同的kafka主题配置Kubernetes部署的微服务的每个pod/进程?

    在我们的应用程序中 有多个不同 kafka 主题的消费者 例如 Cosumer C1 Cosumer C2 Cosumer C3 Cosumer C4 Cosumer C5 以及不同的 kafka 主题 例如主题 1 主题 2 主题 3 主
  • 带有 Kafka 消费者的 Spring Boot 作业调度程序

    我正在开发一个 POC 我想使用来自 Kafka 主题 用户 的消息 尝试实现消费者应该从 Kafka 主题读取消息 一旦 spring boot 调度程序在预定时间或 cron 时间触发 那么我们应该开始从 kafka 主题中一一消费现有
  • 通过 Kafka 消费者重试维持订单保证

    我正在为基于 Kafka 的数据处理管道中的消费者重试设计一个架构 我们正在使用 Kafka 生产者和消费者 并且正在考虑重试主题 如果消费出错 将在这些主题上发送消息 将会有消费者以一定的节奏运行这些重试主题 我读了很多参考架构 但没有一
  • 如何处理Kafka流中的不同时区?

    因此 我正在评估 Kafka Streams 及其功能 看看它是否适合我的用例 因为我需要每 15 分钟 每小时 每天聚合传感器数据 并发现它由于其窗口功能而很有用 因为我可以通过应用创建窗口windowedBy on KGroupedSt
  • 如何在kafka消费组中动态添加消费者

    我应该如何知道何时必须扩展消费者组中的消费者 当存在快速生产者时 消费者扩大规模的触发因素是什么 一种直接的方法是获取消费者延迟 这可以计算为提交的偏移量和开始偏移量之间的差值 如果最后 n 次计算的延迟正在增加 您可以扩大规模 反之亦然
  • 事务性 Kafka 生产者

    我正在尝试让我的卡夫卡生产者具有事务性 我正在发送 10 条消息 如果发生任何错误 则不应向 kafka 发送任何消息 即不发送或全部消息 我正在使用 Spring Boot KafkaTemplate Configuration Enab
  • 是否可以使用Kafka传输文件?

    我每天都会生成数千个文件 我想使用 Kafka 进行流式传输 当我尝试读取该文件时 每一行都被视为一条单独的消息 我想知道如何将每个文件的内容作为 Kafka 主题中的单个消息 以及消费者如何将 Kafka 主题中的每条消息写入单独的文件中
  • Strimzi 运算符 Kafka 集群 ACL 未启用类型:简单

    我们知道要启用Kafka ACL属性authorizer class name kafka security auth SimpleAclAuthorizer要添加到server properties但是如果 Kafka 集群由 Strim
  • kafka消费端Offsets的一致性

    我有复制因子为 3 的卡夫卡主题min insync replicas 2 一个向该主题发送 X 条消息的生产者acks all 一段时间后 1 分钟内 在所有消息发送到主题后 将使用 java kafka 客户端为此主题创建新的消费者 使
  • Kafka:隔离级别的影响

    我有一个用例 我需要 Kafka 分区中的 100 可靠性 幂等性 无重复消息 以及顺序保留 我正在尝试使用事务 API 来建立概念验证来实现这一目标 有一个名为 isolation level 的设置 我很难理解 In this arti
  • Kafka JDBC Sink Connector 对于具有可选字段的模式的消息给出空指针异常

    Kafka JDBC Sink Connector 对于具有可选字段 parentId 的模式的消息给出空指针异常 我错过了什么吗 我正在使用开箱即用的 JSONConverter 和 JDBC Sink Connector 关于 Kafk
  • 带有安全 Kafka 抛出的 Spark 结构化流:无权访问组异常

    为了在我的项目中使用结构化流 我正在 hortonworks 2 6 3 环境上测试 Spark 2 2 0 和 Kafka 0 10 1 与 Kerberos 的集成 我正在运行下面的示例代码来检查集成 我能够在 Spark 本地模式下的
  • Kafka Streams - 跳跃窗口 - 去重键

    我正在 4 小时窗口上进行跳跃窗口聚合 每 5 分钟前进一次 由于跳跃窗口重叠 我得到了具有不同聚合值的重复键 TimeWindows of 240 60 1000L advanceBy 5 60 1000L 如何消除具有重复数据的重复键或
  • Apache kafka - 消费者延迟选项

    我想在 Kafka 中为特定主题稍稍延迟启动一个消费者 具体来说 我希望消费者在从生成消息的时间起经过特定的时间延迟后开始使用该主题的消息 Kafka 中有任何属性或选项可以启用它吗 我们对火花流做了同样的事情 我希望 这种方法也适合您 这
  • Kafka 分区键无法正常工作

    我正在努力解决如何正确使用分区键机制的问题 我的逻辑是设置分区号为3 然后创建三个分区键为 0 1 2 然后使用分区键创建三个KeyedMessage 例如 KeyedMessage 主题 0 消息 KeyedMessage 主题 1 消息
  • 如何使用rest api设置kafka连接auto.offset.reset

    我创建了一个接收器 kafka 连接 将数据转换为其他存储 我想设置auto offset reset as latest当新连接器创建时kafka connect rest api 我已经设定consumer auto offset re
  • 调试自定义 Kafka 连接器的简单有效的方法是什么?

    我正在使用几个 Kafka 连接器 在控制台输出中没有看到它们的创建 部署有任何错误 但是我没有得到我正在寻找的结果 没有任何结果 无论是期望的还是否则 我基于 Kafka 的示例 FileStream 连接器制作了这些连接器 因此我的调试

随机推荐

  • 从表单元素外部的输入标签读取

    我有一个带有输入字段的网页 用于选择日期的日历 问题是我需要从两个不同的表单元素读取输入字段 每个元素都有自己的操作和其他值 calendar do this do that 我不想复制两种表单中的输入字段 因为它看起来很愚蠢 有什么建议么
  • 如何使 SVG 图像动态匹配周围文本的高度 (1em) 和基线?

    是否可以动态调整 SVG 图像的大小 使用 HTML 或 CSS 以匹配周围文本的基线和高度 像这样的东西 在这种情况下 SVG 图像是 Windows 徽标 Image 1 https i stack imgur com Gjyku pn
  • iOS - 实现类似iMessage的滚动效果

    是否可以实现像这样的滚动效果iMessage在 iOS 8 中任何普通UITableView 最好使用 Swift因为它看起来很酷 您正在寻找的是 UIKit Dynamics 我前段时间也对此感兴趣 我参考这个链接来做到这一点 https
  • 更改 cmd 的当前工作目录(从子进程)

    所以我想写一个cd可以使用 cmd 执行的类似程序 并且在退出后 应该更改调用 cmd 进程的工作目录 现在 在这篇文章被标记为重复之前 我知道this https stackoverflow com questions 25944172
  • AddIdentity 与 AddIdentityCore

    在ASP NET Core中 可以添加各种服务进行识别 AddDefaultIdentity AddIdentity and AddIdentityCore 有什么区别AddIdentity and AddIdentityCore AddI
  • 无法将图像解析为 URL:to_model 委托给附件,但在 Rails 5.2 中附件为零

    我有以下表格 div h2 prohibited this user from being saved h2 ul li li ul div
  • 确定 postgres 数值最大值最小值

    在我的 PostgreSQL 表之一中 有一个数据类型为 Numeric 20 10 的属性结果 其输入值之一可以是 无穷大 我想知道长度 20 10 的最大值和最小值是多少 对于一个数字numeric precision scale 极限
  • 如何将向量 转换为向量 /string

    我们有一个遗留方法 它返回一个vectorchar 指针 即vector
  • 学习 C++:返回引用并绕过切片

    我在理解参考资料方面遇到了困难 考虑以下代码 class Animal public virtual void makeSound cout lt lt rawr lt lt endl class Dog public Animal pub
  • 带单引号的 Perl 单行代码

    我使用 Perl 单行语句创建 SQL 语句 但无法包含单引号 这就是我想要的 获取第一个字段并为其添加引号 echo a b perl F lane print F 0 a 我尝试了几种不同的方法 但对我来说没有用 echo a b pe
  • 邮递员表单数据有效,但原始等效项无效

    我有一个正在测试的 API 如果我通过 表单数据 提交具有以下值的数据 则它可以工作 key response comment value This is a test 但是 如果我在 原始 选项卡中使用以下结构执行一些自定义 JSON 则
  • 将非 www/ssl/尾部斜杠的重写与 .htaccess 中的大写->小写结合起来

    因此 我有一个简单的重写来捕获非 www URL 非 SSL url 和缺少尾部斜杠的 url 以重定向到 SSL www 和尾部斜杠 使用
  • 从后端到前端 Yii2 高级应用程序

    我正在尝试将一些控制器从前端链接到后端 几个小时后我不知道问题出在哪里 Backend file main php urlManager gt enablePrettyUrl gt false showScriptName gt false
  • C 中类型转换时的运算符优先级

    下面的代码给出了正确的乘法结果 int var0 245895 int var1 478565 long long val 0 val long long var0 var1 但这篇文章给出了错误的结果 int var0 245895 in
  • MatTable 上的多个过滤器

    我一直在尝试应用多列过滤 即列标题中的文本输入将仅过滤列的内容 到目前为止 我已经能够通过覆盖来使其工作filterPredicate of MatTableDataSource但是一旦我覆盖跨列的默认过滤就不再起作用 export cla
  • firefox flex 不会随着滚动条而增长

    我遇到了特定于 Firefox 的问题 据我所知 在 Chrome 中 如果你有 flex 0 0 auto overflow auto 当 y 方向溢出时 它会占用滚动条的额外宽度 一切都很好 但在 Firefox 中 它不会考虑额外的宽
  • 在 Promise 中断言函数调用

    我正在为异步 Node js 函数编写一些测试 该函数使用 Mocha Chai 和 Sinon 库返回承诺 假设这是我的功能 function foo params return mkdir params then dir gt writ
  • JBoss数据库连接池

    我是 jboss 的新手 我被要求将 jboss 连接池机制与现有的 Web 应用程序合并 考虑到 Web 应用程序数据库层已正确编写 即所有结果集 语句和连接在不需要时正确关闭 在正确配置 jboss 数据源后 我必须在 Web 应用程序
  • Android 中的静电安全吗?

    我在代码中使用一个静态类来定义一个静态字段 我在 Activity onStop onStart 调用之间重用该静态字段 这是一个场景 用户点击 授权 按钮 静态数据初始化 活动停止并调用 Web 浏览器 浏览器执行回调 Activity恢
  • 从客户端检索 Kafka 代理属性

    我想知道是否有一种方法可以使用 shell 命令检索 kafka 代理的所有配置属性 例如 类似的东西 kafka configs sh zookeeper broker ip 2181 entity type brokers descri