kafka-consumer-api - 代码之家

Golang Segmentation在消费者组迁移时获得一半分区

Shubham Snehi · 技术社区 · kafka-partition kafka-consumer-api apache-kafka · 1 年前

从Kaffa主题消费并添加到列表中

Varun Sharma · 技术社区 · kafka-consumer-api apache-kafka python-3.x · 1 年前

添加spring-cloud-starter-bus-Kafka依赖项后,Kafka消费者没有收到消息

Andrey P. · 技术社区 · spring-cloud-bus spring-cloud-config spring-kafka kafka-consumer-api spring · 2 年前

为什么卡夫卡的消费者没有收到经纪人的记录

Evgeniy Zhurenko · 技术社区 · kafka-consumer-api apache-kafka java · 2 年前

Kafka消费者组没有消费来自所有消费者的消息

Dev9321 · 技术社区 · confluent-platform kafka-consumer-api apache-kafka spring java · 2 年前

如何确保旧版本0.10.0在卡夫卡中只处理一次

MrSham · 技术社区 · kafka-consumer-api apache-kafka · 3 年前

如何知道卡夫卡何时提交记录?

BnJ · 技术社区 · kafka-consumer-api apache-kafka · 7 年前

为什么卡夫卡消费者无视我在汽车上的“最早”指令。抵消重置参数,从而不从绝对第一个事件读取我的主题?

addictedtohaskell · 技术社区 · kafka-consumer-api apache-kafka apache-spark scala java · 7 年前

消息预处理(主题-主题)-Kafka Connect API vs.Streams vs Kafka Consumer?

maverick · 技术社区 · apache-kafka-connect kafka-producer-api kafka-consumer-api apache-kafka · 7 年前

如何设置隔离。等级卡夫卡骆驼组件

Renato Garcia · 技术社区 · kafka-consumer-api apache-camel apache-kafka · 7 年前

使用kafka主题中的json值,并使用JQ将其写入csv文件并格式化

Javier · 技术社区 · jq kafka-consumer-api csv json · 7 年前

如何在一个稳定的卡夫卡消费群体中转移话题的偏移量?

Karol Król · 技术社区 · kafka-consumer-api apache-kafka · 7 年前

Spark streaming:错误StreamingContext:无法构造kafka使用者

maxness · 技术社区 · kafka-consumer-api spark-streaming apache-kafka apache-spark · 7 年前

卡夫卡分区分配协议

JJ15k · 技术社区 · kafka-producer-api kafka-consumer-api apache-kafka c# · 7 年前

日志使用kafka 0.11.0调试(“组{}的协调器发现失败,刷新元数据”,groupId)。x个

Jary zhen · 技术社区 · kafka-consumer-api apache-kafka · 7 年前

卡夫卡消费者只给出第一个生成的信息

Bhupender Kumawat · 技术社区 · kafka-consumer-api java · 7 年前

与卡夫卡消费者记录并行流

P K · 技术社区 · kafka-consumer-api apache-kafka java · 8 年前

获取发送给卡夫卡主题的最后一条消息

ryanpudd · 技术社区 · kafka-producer-api kafka-consumer-api apache-kafka · 8 年前

Streamset数据采集器从Kafka读取错误时间

Donat Fetisov · 技术社区 · streamsets confluent-platform kafka-consumer-api timezone · 8 年前

Apache kafka-消费者延迟选项

Sharafath Ahmed · 技术社区 · kafka-consumer-api apache-kafka · 8 年前

Spring JDBC-Kafka消费者的可重试异常

Punter Vicky · 技术社区 · spring-kafka kafka-consumer-api spring-jdbc spring java · 8 年前

春季卡夫卡消费者-打印卡夫卡滞后信息

Punter Vicky · 技术社区 · spring-kafka kafka-consumer-api java · 8 年前

Python KafkaConsumer开始使用来自时间戳的消息

Silithus · 技术社区 · kafka-python kafka-consumer-api apache-kafka python-3.x · 8 年前

如何使用spring kafka为侦听器传递多个引导服务器

daemon54 · 技术社区 · spring-kafka kafka-consumer-api apache-kafka · 8 年前

带有Scala的Kafka流

user1733735 · 技术社区 · apache-kafka-streams kafka-consumer-api apache-kafka scala · 8 年前

Apache Kafka-分区

Sharafath Ahmed · 技术社区 · spring-kafka kafka-consumer-api apache-kafka · 8 年前

如果不挂起,则无法获取KafkaConsumer消息

user2361174 kevin · 技术社区 · kafka-consumer-api apache-kafka python · 8 年前

当主线程睡眠时间小于1000时无法生成消息

Gpwner · 技术社区 · kafka-producer-api kafka-consumer-api apache-kafka · 8 年前

什么是合适的ApacheKafka客户端jar

akd · 技术社区 · kafka-consumer-api apache-kafka java · 8 年前

用于Kafka的Confluent Python API

clay · 技术社区 · confluent-platform kafka-consumer-api apache-kafka python · 9 年前