kafka 异常：return ‘＜SimpleProducer batch=%s＞‘ % self.async ^ SyntaxError: invalid syntax

Python3.X 执行Python编写的生产者和消费者报错，报错信息如下：

Traceback (most recent call last):
File "mykit_kafka_producer.py", line 9, in <module>
from kafka import KafkaProducer
File "/usr/local/lib/python3.7/site-packages/kafka/__init__.py", line 23, in <module>
from kafka.producer import KafkaProducer
File "/usr/local/lib/python3.7/site-packages/kafka/producer/__init__.py", line 4, in <module>
from .simple import SimpleProducer
File "/usr/local/lib/python3.7/site-packages/kafka/producer/simple.py", line 54
return '<SimpleProducer batch=%s>' % self.async
^
SyntaxError: invalid syntax

原因

python3.7新增关键字：async、await；

kafka-python 用到了关键字async，由此带来兼容性问题

解决

使用Python 3.6版本即可正常运行。

注意：先安装 kafka ，然后安装 kafka-python

pip install kafka
pip install kafka-python

kafka 异常：return ‘＜SimpleProducer batch=%s＞‘ % self.async ^ SyntaxError: invalid syntax相关推荐

链接KAFKA异常：Authentication failed during authentication due to invalid credentials with SASL mechanism
使用带kerberos 认证的Kafka客户端链接kafka 创建topic 出现如下异常:Authentication failed during authentication due to inv ...
java异常return笔试题_Java笔试面试总结—try、catch、finally语句中有return 的各类情况...
前言之前在刷笔试题和面试的时候经常会遇到或者被问到 try-catch-finally 语法块的执行顺序等问题,今天就抽空整理了一下这个知识点,然后记录下来. 正文本篇文章主要是通过举例的方式来阐 ...
celery 运行时（from . import async, base）SyntaxError: invalid syntax 异常的解决方案
celery 运行时 (from . import async, base)SyntaxError: invalid syntax 异常的解决方案参考文章: (1)celery 运行时 (from ...
Kafka 异常 : DefaultOffsetCommitCallback.onComplete(ConsumerCoordinator.java:537) -Offset commit faile
Kafka 异常 : DefaultOffsetCommitCallback.onComplete(ConsumerCoordinator.java:537) -Offset commit faile ...
Spring Kafka消费模式（single, batch）及确认模式（自动、手动）示例
目录 1. 单记录消费listener.type=single 1.1 单记录消费 - 自动确认 1.2 单记录消费 - 手动确认 2. 批量消费listener.type=batch 2.1 批量消 ...
【kafka异常】使用Spring-kafka遇到的坑
查看一下压缩策略 bin/kafka-topics.sh --describe --zookeeper xxxx:2181 --topic SHI_TOPIC1 Topic:SHI_TOPIC1 Pa ...
hive3.x异常- return code 1 from org.apache.hadoop.hive.ql.exec.mr.MapredLocalTask
提交joinsql核心异常如下 return code 1 from org.apache.hadoop.hive.ql.exec.mr.MapredLocalTask The value of pr ...
Kafka异常问题记录
一.Kafka关闭后,再次启动失败问题问题描述:kafka关闭后,再次重启失败,异常日志如下: [2022-02-17 16:13:40,739] ERROR Fatal error during ...
Kafka: 异常知其所以然
1. kafka Producer内存不足生产者客户端由两个线程协调运行:主线程和Sender线程(发送线程): 主线程由KafkaProducer创建消息,通过拦截器序列化器跟分区器之后缓存到消息 ...

kafka 异常：return ‘＜SimpleProducer batch=%s＞‘ % self.async ^ SyntaxError: invalid syntax

原因

解决

kafka 异常：return ‘＜SimpleProducer batch=%s＞‘ % self.async ^ SyntaxError: invalid syntax相关推荐

最新文章

热门文章