- 当前热门话题：
Python pykafka
-
本站为您提供最新、最全的pykafka的Python教程、文档、代码、资源等相关内容，Python中文网技术交流社区同时还提供学习资源下载，
如：电子书、IDE编辑器软件、编程视频、代码规范标准、WEB开发、GUI、科学计算与人工智能等相关内容。
本文网址：https://www.cnpython.com/tags/334278
欢迎加入QQ群-->： 979659372
关于pykafka 相关联的Python项目和问题：
最新问答
我希望能够使用pykafka以编程方式在Kafka中创建一个主题。我知道，如果主题不存在，访问TopicDict会自动创建一个主题，但是我不知道如何用它来控制分区/副本的数量。而且，它还有一个讨厌的错 ...
已阅读: n次
我尝试将kafka与python和pykafka一起使用，当我尝试使用linger\ms时，出现以下错误：
TypeError:product（）得到意外的关键字参数“linger\u ms”
这是我 ...
已阅读: n次
我有一个Django项目，我正在使用pykafka。我创建了两个名为producer.py以及消费者.py项目内部。我必须将目录切换到这些文件所在的文件夹中，然后单独运行pythonproducer. ...
已阅读: n次
我是一个新手卡夫卡和皮卡夫卡。我知道，生产者和消费者是在皮卡夫卡通过下面的代码。你知道吗
from pykafka import KafkaClient
client = KafkaClient("l ...
已阅读: n次
我想创建多个消费者并从多个客户机读取数据分区。如果我想创建多个分区，我可以使用命令行创建，如下所示：
python pykafka/cli/kafka_tools.py --broker_versio ...
已阅读: n次
我尝试从here的源代码安装pykafka。我下载了“pykafka-2.8.0”。焦油.gz，然后尝试通过python setup.py develop命令安装。但是，它告诉我一个错误消息TypeE ...
已阅读: n次
我正在尝试使用pykafka和rdkafka来使用消息，但在尝试初始化使用者时出现以下错误。你知道吗
Configuration property "queued.max.messages.kb ...
已阅读: n次
在pykafka中，如何可能在主题的特定分区上发布消息。在下面的代码测试中，主题有四个分区，我打算在其中一个分区中编写每条消息，但显然不是这样工作的。在
from pykafka import Kaf ...
已阅读: n次
我在python的pykafka中使用KafkClient。我试着读一个文本文件，产生一个主题的行，然后由消费者阅读。但是，在运行时，它只读取消息中的单个字母，而不读取文本文件中的单词或行。我做错了什 ...
已阅读: n次
我在gevent中使用pykafka group consumer，但是结果有重复的数据。
显示我的代码：
import gevent
from pykafka import KafkaClient
...
已阅读: n次
如何使用消息批处理或缓冲区与pykafka一起生成kafka主题。我的意思是一个生产者可以在一个生产过程中产生许多信息。我知道使用消息批处理或缓冲消息的概念，但我不知道如何实现它。我希望有人能在这里帮 ...
已阅读: n次
PyKafka的Kafka客户端示例显示了传递给客户端构造函数的Kafka节点：
from pykafka import KafkaClient
client = KafkaClient(hosts= ...
已阅读: n次
最新项目
brod允许您向kafka分布式发布/订阅消息服务生成消息。它最初是Pykafka的一个分支（https://github.com/dsully/Pykafka），但由于我们需要添加许多特性 ...
已阅读: n次
皮卡夫卡
pykafka是一个面向python的程序员友好的kafka客户机。它包括python
Kafka生产者和消费者的实现，它们可以选择支持
通过在librdkafka ...
已阅读: n次
这是一个围绕pykafka的robot框架包装器，是目前为止最好的python-kafka库，也是唯一一个支持kafka 1.0和1.1的库。
此包Python名称 ...
已阅读: n次
pykafka工具扩展了python pykafka模块的功能。
此包Python名称：pykafka-tools
目前版本： pykafka-to ...
已阅读: n次
