程序员经验分享-hwhale

错误：包 org.apache.kafka.clients. Producer 没有

2024-02-01

我是卡夫卡新手。当我运行这个命令时

javac -cp "C:\kafka\kafka_2.11-0.10.2.0\libs\kafka-clients-0.10.2.0.jar" *.java

我收到一条错误消息

错误：包 org.apache.kafka.clients. Producer 不存在


除了@Abhishek 的回答：-

首先从以下位置下载 Kafka-clients 库依赖项https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients

复制org文件夹并将其粘贴到lib我们的 Kafka 主目录的文件夹。

然后运行上面两个给定的命令

它也可以通过简单的命令运行：-

javac -cp libs *.java

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

ApacheKafka

kafkaproducerapi

错误：包 org.apache.kafka.clients. Producer 没有 的相关文章

  • 使用 Kafka Streams 在输出中设置时间戳无法进行转换

    假设我们有一个变压器 用 Scala 编写 new Transformer String V String V var context ProcessorContext override def init context Processor

  • Spark：将 bytearray 转换为 bigint

    尝试使用 pyspark 和 Spark sql 将 kafka 键 二进制 字节数组 转换为 long bigint 会导致数据类型不匹配 无法将二进制转换为 bigint 环境详情 Python 3 6 8 Anaconda custo

  • 具有替代方案的重载方法值表

    我有编译器抱怨的以下代码 val state KTable String String builder table BARY PATH Materialized as PATH STORE 错误信息 error home developer

  • 如何使用 haproxy 负载均衡器 Kafka Bootstrap？

    我有一个 kafka 集群 由 3 台在 AWS 上运行的机器组成 卡夫卡1到卡夫卡3 我正在使用新型卡夫卡消费者 gt 0 8 我知道kafka客户端连接到其中一台kafka服务器 获取服务器元数据 然后直接连接到代理 我想确保在代理发生

  • 在SSL模式下使用apache kafka

    我正在尝试在 SSL 1 way 模式下设置 kafka 我已经阅读了官方文档并成功生成了证书 我将记下两种不同情况的行为 此设置只有一名经纪人和一名动物园管理员 案例 1 经纪人间通信 明文 我的相关条目server properties

  • 如何在kafka消费组中动态添加消费者

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

  • Grafana/prometheus 中没有 kafka 指标

    我成功部署了 Helm Chart普罗米修斯操作员 https github com coreos prometheus operator tree master helm prometheus operator kube 普罗米修斯 ht

  • 如何使用 C# 从 Kafka 获取主题列表

    我想从卡夫卡获取主题列表 我正在使用 kafka net 客户端 但无法在有关获取主题列表的文档中找到 您可以使用 Confluence Kafka 包中提供的 AdminClient 列出所有主题 using Confluent Kafk

  • kafka Avro 多个主题的消息反序列化器

    我正在尝试以 avro 格式反序列化 kafka 消息 我使用以下代码 https github com ivangfr springboot kafka debezium ksql blob master kafka research c

  • 命名 kafka 主题的最佳实践是什么？

    我们是 kafka 的新手 我们有几个团队正在开发一些相互发布 订阅事件的应用程序 由于kafka主题名称将在团队之间共享 那么命名有什么最佳实践吗 基本上我们不希望看到 A 团队命名主题companyname appname events

  • Kafka - 如何同时使用过滤器和过滤器？

    我有一个 Kafka 流 它从一个主题获取数据 并且需要将该信息过滤到两个不同的主题 KStream

  • 编辑 Kafka Listener Spring 应用程序以更改阶段/目标

    我可以利用另一个运行 Kafka 应用程序 代码库的团队来使用相同的数据 将其加载到我们的新暂存表中 而不是他们的 他们在 Messages 文件夹中有许多不同的 kafka 侦听器适配器 java 文件 每个文件消耗不同类型的数据 每个

  • 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

  • 使用表白名单选项更新 Debezium MySQL 连接器

    我正在使用 Debezium 0 7 5 MySQL 连接器 并且我试图了解如果我想使用以下选项更新此配置 最好的方法是什么table whitelist 假设我创建了一个连接器 如下所示 curl i X POST H Accept ap

  • Apache Kafka 是否提供异步订阅回调 API？

    我的项目正在将 Apache Kafka 视为老化的基于 JMS 的消息传递方法的潜在替代品 为了让这个过渡尽可能的顺利 如果替代的排队系统 Kafka 有一个异步订阅机制那就更理想了 类似于我们当前项目使用的JMS机制MessageLis

  • 如何在 Python 中以编程方式检查 Kafka Broker 是否已启动并运行

    我正在尝试使用来自 Kafka 主题的消息 我正在使用包装器confluent kafka消费者 我需要在开始使用消息之前检查连接是否已建立 我读到消费者很懒 所以我需要执行一些操作才能建立连接 但我想检查连接建立而不执行consume o

  • 为每个键使用主题中的最新值

    我有一个 Kafka 生产者 它正在以高速率生成消息 消息键是用户名 值是他在游戏中的当前分数 Kafka消费者处理消费消息的速度相对较慢 在这里 我的要求是显示最新的分数并避免显示陈旧的数据 但代价是某些分数可能永远不会显示 本质上 对于

  • kafka消费者群体正在重新平衡

    我正在使用 Kafka 9 和新的 java 消费者 我正在循环内进行轮询 当代码尝试执行 Consumer commitSycn 时 由于组重新平衡 我收到 commitfailedexcption 请注意 我将 session time

  • Kafka：如何获取主题的最后修改时间，即添加到主题的任何分区的最后一条消息

    我们的用例是从 kafka 中删除陈旧 未使用的主题 即如果某个主题 在所有分区上 在过去 7 天内没有任何新消息 那么我们会将其视为陈旧 未使用并删除它 许多谷歌结果建议向消息添加时间戳 然后解析它 对于新主题和消息 灵魂可以工作 但我们

随机推荐

  • 如何在流程图上自动布局框？

    我有一些代表流程图的数据 一堆 Jira 状态及其向其他状态的转换 我也有定位每个流程图项目的粗略方法 https stackoverflow com questions 3961734 how do i generate an openo

  • Windows Installer 实例转换如何与升级交互？

    我创建了一个安装包 通过 WIX 它利用实例转换来允许在一台计算机上多次安装 没有经过太多思考 我还添加了对重大升级的支持 就像我之前多次做过的那样 今天 第一次安装了该产品的新版本 其行为并不完全符合我的预期 即使安装是针对新实例 但似乎

  • 使用 WebPack，如何创建可供使用的“拆分”捆绑包，其中一个捆绑包依赖于另一个捆绑包？

    我的问题非常接近others https stackoverflow com questions 34602831 webpack build bundle without dependencies我的回答是believe仍然需要另一个我想

  • 如何在 Cocoa 中创建 Daemon 应用程序？

    我是新手 谁能帮助我如何在 Cocoa 中创建守护进程应用程序 浏览了这里的资源 但我无法正确理解 两天以来 这里一直受到袭击 该应用程序应该是一个基础工具吗 代码应该用C写吗 我应该如何实施 launchd 我找不到完整的导师吗 请帮帮我

  • 获取MenuItem材质ui的值

    我在用着材质用户界面 https material ui com 对于菜单和菜单项 我试图获取菜单项的值 但它不起作用 这是我的代码 menu value menu

  • 使用 SAXparser 获取多个元素的信息 (Android)

    我是 Android 新手 也是 Java 新手 但现在我开始使用 Web 服务 因此 为了更好地理解如何解析 XML 我开始尝试本教程 http www anddev org novice tutorials f8 parsing xml

  • 删除另一列中具有多个唯一值的组

    我有一个类似的excel Name X Y A 5 9 B 5 10 C 7 9 D 7 9 E 5 10 F 5 8 我想删除 Y 列中具有重复值但 X 列中具有不同值的行 换句话说 如果一个 Y 值对应多个 X 值 则删除所有这些行 结

  • 使用名称空间前缀解组肥皂响应

    我正在尝试使用 jaxb 解组肥皂响应 我尝试使用以下代码来查找根元素 DocumentBuilderFactory dbf DocumentBuilderFactory newInstance dbf setNamespaceAware

  • 如何从 Mongoose 数组中删除嵌套对象

    这是我的第一个 Web 应用程序 我需要删除嵌套数组项 如何使用以下模式删除 Mongoose 中的对象 User event id 12345 title this id 12346 title that 我该如何删除id 12346在猫

  • Xpath 是正确的仍然没有得到这样的元素：无法定位元素

    我的 Xpath 是正确的 没有 iFrame 我可以在 Chrome 控制台中找到元素 但我的程序仍然失败 我也使用了显式等待 website http newtours demoaut com http newtours demoaut

  • ScrollView 内容未填充 SwiftUI

    我有一个滚动视图 其内容是VStack包含一个 ForEach 循环来创建一些行而不是列表 列表有一些缺点 例如分隔符 我的问题是行没有填充滚动视图 我认为滚动视图宽度没有填满屏幕 NavigationView Toggle isOn on

  • 为什么打印函数时输出总是为 1？

    我想知道为什么当我打印这个函数时 输出总是为 1 这是代码 include

  • Swift 3.0 排序 - 传递给不带参数的调用的参数

    我目前正在尝试将一些 Swift 2 代码移植到 Swift 3 0 这是一行让我发疯的代码 public private set var searchHistory SearchHistoryEntry SearchHistoryEntr

  • “重新加载”的递归版本

    当我开发 Python 代码时 我通常会在解释器中以临时方式对其进行测试 患病的import some module 测试一下 发现bug 修复bug并保存 然后使用内置的reload功能为reload some module 并再次测试

  • .NET MAUI - 如何在标题栏中放置按钮？

    在我的 NET MAUI 项目中 我想在标题栏中放置一个按钮 TitleBar 本身是通过设置 ContentPage 的 Title 自动生成的 有谁知道如何在那里放置一个按钮 根据杰森和史蒂夫的建议 您可以使用Shell TitleVi

  • 使用 .* 宽度说明符调用 sprintf 时出现奇怪警告

    对于以下代码 https godbolt org z WcGf9hEs3 https godbolt org z WcGf9hEs3 include

  • Jenkins - 从文件系统而不是 SCM 加载全局管道库？

    我在文档中找不到有关如何执行此操作的任何内容 有人有任何想法吗 目前看来是不可能的 但是您可以轻松地初始化本地 git 存储库并将其用作 SCM 而无需任何远程托管 要初始化 git 存储库 请在共享库的根目录 例如 C Users Jen

  • 为什么不应该禁用 ONLY_FULL_GROUP_BY

    在互联网搜索过程中 我现在看到很多需要禁用的问题ONLY FULL GROUP BY功能 因此这意味着很多开发人员在这种严格模式下编写 SQL 查询时遇到麻烦 我知道禁用此限制非常简单 但现在我问一个问题 为什么我不应该这样做 去除后会涉及

  • TestFlight beta 测试 iOS 应用

    我完成了我的第一个应用程序的开发 现在我想通过以下方式分发我的测试版https testflightapp com https testflightapp com 我尝试使用本教程创建 ipa 文件 http help testflight

  • 错误：包 org.apache.kafka.clients. Producer 没有

    我是卡夫卡新手 当我运行这个命令时 javac cp C kafka kafka 2 11 0 10 2 0 libs kafka clients 0 10 2 0 jar java 我收到一条错误消息 错误 包 org apache ka

热门标签