apache-kafka - 代码之家

使用KSQL计算所有条目

Tim.G. · 技术社区 · ksqldb apache-kafka-streams apache-kafka · 7 年前

spring cloud starter stream kafka并没有创建提供给spring的主题。靴子云流动绑定。输出目的地

Niks · 技术社区 · docker-compose apache-kafka spring-boot docker java · 7 年前

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

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

什么可能导致卡夫卡“消费者补偿”主题的巨大负载?

Seweryn Habdank-Wojewódzki · 技术社区 · consumer internal load apache-kafka performance · 7 年前

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

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

卡夫卡制作人挂起发送

Eugen · 技术社区 · kafka-producer-api apache-kafka apache-spark hadoop scala · 7 年前

无法使用Golang Sarama包使用来自本地运行Kafka服务器的消息

ÑÐ°Ð½Ð¶Ð°Ñ ÐºÑÐ»Ð¸ÐµÐ² · 技术社区 · sarama telegram-bot apache-kafka go · 7 年前

使用Servlet连接KafkaProducer

Vaibhav Sharma · 技术社区 · apache-kafka-connect kafka-producer-api apache-kafka · 7 年前

卡夫卡直接在磁盘上写数据?

Akinn · 技术社区 · ram apache-kafka filesystems · 7 年前

使用卡夫卡主题存储数据多年

Mikhail Tsaplin · 技术社区 · apache-kafka · 7 年前

卡夫卡组协调器在0.11.0.1上故障恢复

Yamada · 技术社区 · apache-kafka · 7 年前

使用ConsumerKafka处理器时创建更大的NiFi流文件

Ben Watson · 技术社区 · apache-nifi apache-kafka hadoop · 7 年前

Kafka控制台消费者无法连接到AWS EC2服务器上的zookeeper服务器

Sourav Das · 技术社区 · apache-kafka amazon-ec2 · 7 年前

如何删除/清除卡夫卡流中的状态存储?

blahblah · 技术社区 · apache-kafka-streams apache-kafka · 7 年前

Apache kafka-消费者延迟选项

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

kafka输入插件连接到IBM Message Hub时出现不可恢复的错误

Chris Snow · 技术社区 · message-hub logstash apache-kafka elasticsearch · 7 年前

Kafka+Spark流媒体-分区之间的公平性?

John Humphreys · 技术社区 · spark-streaming apache-kafka apache-spark · 7 年前

Spring Kafka consumer-带恢复回调机制的手动提交

Punter Vicky · 技术社区 · spring-kafka kafka-consumer-api apache-kafka spring-boot spring · 7 年前

Zookeeper安装不适用于windows 10

Hunter · 技术社区 · apache-zookeeper windows-10 apache-kafka · 7 年前

消费者如何指定要读取的分区?[卡夫卡]

gstackoverflow · 技术社区 · consumer partition apache-kafka java · 7 年前

Python Kafka多进程与线程

Deven · 技术社区 · python-multithreading python-multiprocessing apache-kafka python · 7 年前

Zookeeper如何使用SASL身份验证设置其zNode权限?

aran · 技术社区 · ambari kerberos apache-zookeeper apache-kafka · 7 年前

卡夫卡的平行生产与消费

mofury · 技术社区 · apache-kafka · 7 年前

如何在Kubernetes中对外公开StatefulSet的无头服务

Nadir Muzaffar · 技术社区 · kubernetes apache-kafka · 7 年前

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

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

Apache kafka消费者轮询意外消息的无限循环

Ali Ben Zarrouk · 技术社区 · docker-compose apache-kafka docker java · 7 年前

卡夫卡消费者api(无zookeeper配置)

Adam Lee · 技术社区 · apache-kafka · 7 年前

很难让简单的卡夫卡制作人继续

Rob · 技术社区 · kafka-python apache-kafka python · 7 年前

Kafka Streams API中的ArrayList Serde问题

Evaldas Buinauskas · 技术社区 · apache-kafka-streams apache-kafka java · 7 年前

Flink Kafka-如何使应用程序并行运行?

Sub Zero · 技术社区 · apache-flink apache-kafka parallel-processing java · 7 年前