Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
无法向 Kafka 发送大消息
我想从生产者向 Kafka 发送一条大消息 因此我更改了以下属性 代理 服务器 属性 replica fetch max bytes 317344026 message max bytes 317344026 max message byt
python27
ApacheKafka
max
kafkaproducerapi
kafkapython
如何强制消费者读取kafka中的特定分区
我有一个应用程序 用于从 1 个 Kafka 生产者生成的 URL 流中下载特定的 Web 内容 我创建了一个有 5 个分区的主题 有 5 个 kafka 消费者 但网页下载的超时时间为 60 秒 当下载其中一个 URL 时 服务器会假设消
ApacheKafka
kafkapython
Python KafkaConsumer 从某个时间戳开始消费消息
我计划跳过主题的开头 只读取从某个时间戳到结束的消息 关于如何实现这一目标有任何提示吗 我猜你正在使用kafka python https github com dpkp kafka python https github com dpkp
python3x
ApacheKafka
kafkaconsumerapi
kafkapython
kafka消费者寻求不起作用:AssertionError:未分配的分区
卡夫卡消费者con当我尝试从我的主题接收消息时 下面定义的效果非常好 但是 当我尝试使用更改偏移量时 这给我带来了麻烦seek方法或其任何变体 IE seek to beginning seek to end from kafka impo
kafkaconsumerapi
seek
kafkapython
Kafka 发送重复消息
我们使用 kafka 0 9 0 0 来编排不同微服务之间的命令消息 我们发现一个间歇性问题 即重复消息被传递到特定主题 下面给出了发生此问题时出现的日志 有人可以帮助理解这个问题吗 Wed 21 Sep 2016 09 19 07 WAR
ApacheKafka
kafkaconsumerapi
kafkapython
kafka-python 中的多处理
我一直在使用 python kaka 模块从 kafka 代理中消费 我想并行使用具有 x 个分区的同一主题 该文档有这样的内容 Use multiple consumers in parallel w 0 9 kafka brokers
ApacheKafka
kafkaconsumerapi
kafkapython
如何使用 ssl 配置创建 Kafka-python 生产者
我正在尝试使用 ssl 创建 kafka 生产者 我需要有关如何在构造函数中设置 SSL 参数的信息 kafka python 客户端中提供的信息描述性不够 什么是ssl certfile ssl cafile ssl keyfile参数
kafkapython
如何使用kafka-python订阅多个kafka通配符模式的列表?
我使用带有通配符的模式订阅 Kafka 如下所示 通配符代表动态客户 ID consumer subscribe pattern customer validations 这很有效 因为我可以从主题字符串中提取客户 ID 但现在我需要扩展功
python
ApacheKafka
kafkapython
如何使用 kafka 使用 python 连接 JDBC 接收器和源
我想从一个系统直播到另一个系统 我正在使用 kafka python 并且能够在本地进行直播 发现连接器可以处理多个设备 有人可以建议我一种使用连接器在 python 中实现它的方法吗 Kafka Connect 是一个 Java 框架 而
ApacheKafka
apachekafkaconnect
kafkapython
Kafka Consumer:如何在Python中从最后一条消息开始消费
我正在使用 Kafka 0 8 1 和 Kafka python 0 9 0 在我的设置中 我有 2 个 kafka 经纪人设置 当我运行我的 kafka 消费者时 我可以看到它从队列中检索消息并跟踪两个代理的偏移量 一切都很好 我的问题是
python
ApacheKafka
kafkaconsumerapi
kafkapython
所有消息消费完后如何关闭kafka消费者?
我有以下程序来消耗所有传入 Kafka 的消息 from kafka import KafkaConsumer consumer KafkaConsumer my test topic group id my group bootstrap
python
ApacheKafka
kafkaconsumerapi
kafkapython