我的生产端应该没问题，也成功创建了一个主题sex。
但我的消费端不知道为什么消费不了，报这样的错。
这是我消费端的代码
使用python代码在kafka集群下报错
我的生产端应该没问题，也成功创建了一个主题sex。
但我的消费端不知道为什么消费不了，报这样的错。
这是我消费端的代码
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
0条回答 默认 最新
- 2022-09-01 17:56回答 2 已采纳 似乎是权限问题，你可以看看报错的文件路径权限组看看，使用 ls -l /home/…
- 2022-05-15 21:27回答 1 已采纳 删除异常的主题“movie_real_topic”试试.\bin\kafka-topics --delete --topic movie_real_topic --zookeeper localhos
- 2021-08-16 15:59回答 1 已采纳 应该可以，不过通常使用scala语言进行编写
- 2019-10-23 10:38「已注销」的博客 首先flink在1.9才开始支持支持python的。开发主要思路是要先把源码编译成python的依赖包，然后用pip命令把包集成到python库。 安装命令如下: 1.git clone https://github.com/apache/flink.git 2.git fetch origin ...
- 2022-03-29 11:08回答 2 已采纳 报错信息显示cluster id 不匹配，修改下 meta.properties中的cluster.id值
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2022-07-21 16:59回答 1 已采纳 内部是9092端口，外部用31082端口
- 2024-07-17 15:54passion更好的博客 ：Kafka 中的消息被分类存储在名为 topic 的容器中。：同一个消费者群组内的消费者可以并行地消费同一个 topic 的不同分区，但每个分区只能被一个消费者群组内的一个消费者消费，以确保消息的有序性。：Kafka 中的每...
- 2019-07-10 23:36回答 3 已采纳 https://www.cnblogs.com/yxlblogs/p/10115672.html 这个重新安装kafka 后问题解决，原来的使用String Serializable 也不行
- 2021-08-25 12:07回答 1 已采纳 你看第二行，已经告诉你异常了。“Disconnected while requesting ApiVersion: might be caused by incorrect security.prot
- 2021-04-19 17:13回答 2 已采纳 连接问题 检查下ip和端口
- 2020-04-29 16:11爱编程的喵喵的博客 1. 什么是kafka 1.1 基本概述 1.2 深度讲解 2. kafka的安全机制 3. python_API 3.1 作为生产者连接kafka并发送数据
- 2022-08-04 12:05回答 2 已采纳 看下这篇博客，也许你就懂了，链接：python的kafka客户端你还可以看下python参考手册中的 python- 接下来？
- 2020-02-15 21:29python 一语呢喃的博客 今天小编就为大家分享一篇在python环境下运用kafka对数据进行实时传输的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧 背景： 为了满足各个平台间数据的传输，以及能确保历史性和实时性。...
- 2023-04-24 19:23羌俊恩的博客 这明显在生产环境，这种认证方式时不符合实际业务场景的。allow.everyone.if.no.acl.found=true #false的话就只能超级用户才能访问资源，true的话其他也可以，如果用户读写一个 Topic，但是没有配置 ACL 权限，...
- 没有解决我的问题, 去提问
问题事件
系统已结题
12月25日
创建了问题
12月17日
悬赏问题
- ¥15 is not in the mmseg::model registry。报错，模型注册表找不到自定义模块。
- ¥15 安装quartus II18.1时弹出此error，怎么解决？
- ¥15 keil官网下载psn序列号在哪
- ¥15 想用adb命令做一个通话软件，播放录音
- ¥30 Pytorch深度学习服务器跑不通问题解决？
- ¥15 部分客户订单定位有误的问题
- ¥15 如何在maya程序中利用python编写领子和褶裥的模型的方法
- ¥15 Bug traq 数据包 大概什么价
- ¥15 在anaconda上pytorch和paddle paddle下载报错
- ¥25 自动填写QQ腾讯文档收集表