weixin_52225937 2022-12-17 14:06 采纳率: 90.2%
浏览 13
已结题

使用python代码在kafka集群下报错

img


我的生产端应该没问题，也成功创建了一个主题sex。

img


但我的消费端不知道为什么消费不了，报这样的错。

img


这是我消费端的代码

  • 写回答

0条回答 默认 最新

    报告相同问题？

    • python flink 1.9 环境搭建 - 处理kafka实例化报错
      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 ...
    • Kafka消息队列python开发环境搭建
      2024-07-17 15:54
      passion更好的博客 ：Kafka 中的消息被分类存储在名为 topic 的容器中。：同一个消费者群组内的消费者可以并行地消费同一个 topic 的不同分区，但每个分区只能被一个消费者群组内的一个消费者消费，以确保消息的有序性。：Kafka 中的每...
    • 从小白的角度讲解kafka并使用java、python_API实战
      2020-04-29 16:11
      爱编程的喵喵的博客 1. 什么是kafka 1.1 基本概述 1.2 深度讲解 2. kafka的安全机制 3. python_API 3.1 作为生产者连接kafka并发送数据
    • 在python环境下运用kafka对数据进行实时传输的方法
      2020-02-15 21:29
      python 一语呢喃的博客 今天小编就为大家分享一篇在python环境下运用kafka对数据进行实时传输的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧 背景： 为了满足各个平台间数据的传输，以及能确保历史性和实时性。...
    • 单机 搭建kafka集群 本地_kafka集群部署以及单机部署
      2021-01-13 05:20
      刘万祥ExcelPro的博客 kafka单机部署一.环境准备当前环境：centos7.3一台软件版本：kafka_2.12部署目录：/usr/local/kafka启动端口：9092配置文件：/usr/local/kafka/config/server.propertiesyum依赖yum install java-1.8.0-openjdk需要...
    • Kafka集群多用户访问权限分治和消息共享配置指导
      2023-04-24 19:23
      羌俊恩的博客 这明显在生产环境，这种认证方式时不符合实际业务场景的。allow.everyone.if.no.acl.found=true #false的话就只能超级用户才能访问资源，true的话其他也可以，如果用户读写一个 Topic，但是没有配置 ACL 权限，...
    • kafka基础知识
      2022-06-28 15:26
      fan_bigdata的博客 kafka 是最初由 linkedin 公司开发的，使用 scala 语言编写，kafka 是一个分布式，分区的，多副本的，多订阅者的日志系统（分布式 MQ 系统），可以用于搜索日志，监控日志，访问日志等。kafka 目前支持多种客户端的...
    • Kafka详解
      2024-07-25 09:56
      double_Light的博客 Windows-UI可视化客户端我们连接时使用IP地址进行连接，云上连接，相当于内网连接如果是其他部署（区分内外网访问，docker中类似），可能需要在服务器配置文件中进行广播地址的修改，config/server.properties，修改...
    • Kafka 在大数据电商系统中的应用案例
      2025-12-15 16:11
      AI Python 编程的博客 Apache Kafka作为分布式流处理平台高吞吐量：单节点支持百万级TPS，轻松应对大促流量；低延迟：端到端延迟低至毫秒级，满足实时场景需求；高可靠性：多副本机制（默认3副本），确保数据不丢失；灵活的扩展性：支持...
    • Kafka 线上性能调优
      2024-04-19 01:44
      2401_84080278的博客 Kafka 线上性能调优是一项综合工程，不仅仅是 Kafka 本身，还应该从硬件（存储、网络、CPU）以及操作系统方面来整体考量，首先我们要有一套生产部署方案，基于这套方案再进行调优，这样就有...Kafka 集群整体的稳定性。
    • 没有解决我的问题, 去提问

    问题事件

    • 系统已结题 12月25日
    • 创建了问题 12月17日