Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Kafka Consumer 挂在 java 中的 .hasNext 处
我有一个简单的 Java Kafka Consumer 代码如下 public void run ConsumerIterator
Java
Multithreading
ApacheKafka
在某些代理关闭后如何更改主题领导者或删除分区?
我们有一个带有 4 个代理的 kafka 集群 以及一些具有副本因子 1 和 10 分区的主题 某一时刻 我们的 4 台服务器中的 2 台与 kafka 集群发生故障 现在我们有 2 个具有相同主题的经纪人 当我运行命令时 kafka to
ApacheKafka
apachezookeeper
在 Windows Kafka 上删除主题时出现 AccessDeniedException
我刚刚在我的 Windows 机器上安装了 Kafka 来自 Confluence Platform 我启动了 Zookeeper 和 Kafka 并创建主题 生产和消费它们的工作 然而 一旦我删除一个主题 Kafka 就会崩溃 如下所示
Windows
ApacheKafka
confluentplatform
pyspark.sql.utils.AnalysisException:找不到数据源:kafka
我正在尝试使用 pyspark 从 kafka 读取流 我在用Spark 版本 3 0 0 preview2 and 火花流 kafka 0 10 2 12在此之前 我只是统计了zookeeper kafka并创建了一个新主题 usr lo
卡夫卡主题_授权_失败
我实际上正在努力使用 SASL 纯文本设置简单的 Kafka 身份验证并添加 ACL 授权 但当我尝试使用数据时遇到问题 main INFO org apache kafka common utils AppInfoParser Kafka
ApacheKafka
ACL
jaas
卡夫卡模式订阅。新主题未触发重新平衡
根据有关的文档卡夫卡java文档 if I 订阅模式 创建与模式匹配的主题 应该进行重新平衡 这使得消费者可以阅读该新主题 但这并没有发生 如果我停止并启动消费者 它确实会获取新主题 所以我知道新主题符合模式 这个问题可能有重复https
Java
ApacheKafka
kafkaconsumerapi
无法在 Kafka Stream 应用程序的 IDE 中删除状态目录
我正在开发一个简单的 Kafka Stream 应用程序 它从一个主题中提取消息并在转换后将其放入另一个主题中 我正在使用 Intelij 进行开发 当我调试 运行这个应用程序时 如果我的 IDE 和 Kafka 服务器位于同一台机器 即
Java
Windows
ApacheKafka
apachekafkastreams
Kafka Streams如何获取kafka headers
我有下面的卡夫卡流代码 public class KafkaStreamHandler implements Processor
Java
ApacheKafka
apachekafkastreams
将文件分区为日期从 kafka 写入 hdfs 的最有效方法是什么
我正在开发一个应该通过 kafka 写入 hdfs 的项目 假设有一个在线服务器将消息写入kafka 每条消息中都包含时间戳 我想创建一个作业 其输出将是根据消息中的时间戳的一个或多个文件 例如如果kafka中的数据是 ts 01 07 2
Hadoop
HDFS
ApacheKafka
Kafka 多分区排序
我知道在 Kafka 中不可能对多个分区进行排序 并且分区排序仅保证组内的单个消费者 对于单个分区 然而 使用 Kafka Streams 0 10 现在可以实现这一目标吗 如果我们使用时间戳功能 以便每个分区中的每条消息都保持顺序 那么在
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
apachekafkastreams
如何使用嵌入到Spring Cloud Stream中的kafka创建单元测试
抱歉 这个问题太笼统了 但是有人有一些关于如何使用嵌入的 kafka 执行生产者和消费者测试的教程或指南 我已经尝试了几个 但是有多个版本的依赖项 但没有一个真正起作用 我正在使用春云流卡夫卡 我们通常建议使用测试粘合剂在测试中 但如果你想
JUnit
ApacheKafka
springCloud
springKafka
springcloudstream
如何在kafka中创建新的消费者组
我按照快速入门指南上的说明在本地运行 kafkahere 然后我在中定义了我的消费者组配置config consumer properties这样我的消费者就可以从定义的中选择消息group id 运行以下命令 bin kafka cons
ApacheKafka
kafkaconsumerapi
Kafka 服务器配置 - 侦听器与广告侦听器
要让 Kafka 运行 您需要设置一些属性config server properties文件 有两个设置我不明白 有人可以解释listeners 和advertising listeners 属性之间的区别吗 文档说 Listeners
ApacheKafka
群组成员支持的协议与现有成员的协议不兼容
我面临与卡夫卡相关的问题 我正在使用当前的服务 Producer 将消息发送到 Kafka 主题 events 该服务正在使用kafka 2 12 v1 0 0 用 Java 编写 我正在尝试将其与示例项目集成spark streaming
apachespark
ApacheKafka
SparkStreaming
使用Kafka Connect时如何转换所有时间戳字段?
我正在尝试将所有时间戳字段转换为格式为字符串类型yyyy MM dd HH mm ss 要转换多个字段 我必须为每个字段单独创建一个转换 transforms tsFormat1 tsFormat2 tsFormatN transforms
ApacheKafka
apachekafkaconnect
如何检查Kafka Consumer是否准备好
我将 Kafka 提交策略设置为最新 但缺少前几条消息 如果我在开始向输入主题发送消息之前休息 20 秒 那么一切都会按预期进行 我不确定问题是否在于消费者花费很长时间进行分区重新平衡 有没有办法在开始轮询之前知道消费者是否准备好 您可以使
ApacheKafka
rebalancing
如何将主题动态传递给kafka监听器?
几天以来 我一直在尝试将主题动态传递给 Kafka 侦听器的方法 而不是通过 Java DSL 中的键使用它们 周围有人以前做过这件事 或者可以阐明实现这一目标的最佳方法是什么 我发现最简单的解决方案是使用 SpEL Autowired p
Java
ApacheKafka
kafkaconsumerapi
Kafka Connect 启动失败
我在新的linux centos 7上安装了kafka confluence oss 4 0 但kafka连接无法启动 重现步骤 Install Oracle JDK 8 Copy confluent 4 0 0 folder on opt
ApacheKafka
apachekafkaconnect
confluentplatform
如何获取kafka偏移量数据,在时间戳上指定
I ve 试图获得偏移量当我尝试运行时 基于时间戳的 Kafka 主题抛出空指针错误 Map
Java
ApacheKafka
kafkaconsumerapi
所有消息消费完后如何关闭kafka消费者?
我有以下程序来消耗所有传入 Kafka 的消息 from kafka import KafkaConsumer consumer KafkaConsumer my test topic group id my group bootstrap
python
ApacheKafka
kafkaconsumerapi
kafkapython
«
1 ...
34
35
36
37
38
39
40
»