apache-kafka - 代码之家

缺少所需的配置“key.converter”,该配置没有defau

andrea cenciarelli · 技术社区 · apache-kafka-connect apache-kafka · 6 年前

Java-了解方法签名

Joe · 技术社区 · apache-kafka methods generics java · 6 年前

如何在Scala中实现Java接口(针对Kafka)?

Joe · 技术社区 · apache-kafka scala java · 6 年前

Scala—如何将回调传递给方法

Joe · 技术社区 · apache-kafka scala java · 6 年前

从Python notebook向在GCP中运行的独立spark群集提交应用程序

user2277675 · 技术社区 · apache-kafka apache-spark python-3.x · 6 年前

数据在kafka服务器中存储多长时间?

Sanjiv · 技术社区 · apache-kafka · 6 年前

卡夫卡例外后的根本原因

vatsal mevada · 技术社区 · kafka-producer-api apache-kafka · 6 年前

卡夫卡流:Lib Rocks数据库上的UnsatifiedLinkError

mukesh210 · 技术社区 · rocksdb apache-kafka-streams apache-kafka scala · 6 年前

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

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

无法启动zookeeper服务器

user9467051 · 技术社区 · apache-zookeeper port apache-kafka · 6 年前

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

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

消费者失败时的卡夫卡行为

Sergey · 技术社区 · message-queue apache-kafka java · 6 年前

卡夫卡无法接收来自外部制作人的消息

Alan Gaytan · 技术社区 · apache-kafka · 6 年前

在foreachRDD中使用变量时,是否需要使用广播变量?

John Doe · 技术社区 · apache-kafka apache-spark scala · 6 年前

从Apache Kafka中的主题删除消息

Dani · 技术社区 · apache-kafka java · 6 年前

MySQL的Debezium刷新超时和OutOfMemoryError错误

Kamil Sindi · 技术社区 · debezium apache-kafka-connect apache-kafka mysql java · 6 年前

卡夫卡复制系数增加发布后

D Developer · 技术社区 · replication apache-kafka · 6 年前

Spark Streaming kafka偏移量管理

Frank · 技术社区 · spark-streaming-kafka offset spark-streaming apache-kafka apache-spark · 6 年前

在docker容器中运行kafka

Alan Gaytan · 技术社区 · dockerfile apache-kafka docker · 6 年前

分区创建中的Kafka数据行为

Andrés Cidoncha Carballo · 技术社区 · apache-kafka · 6 年前

将卡夫卡数据消费到HDFS Spark Batch

Havnar · 技术社区 · hdfs apache-kafka apache-spark · 6 年前

docker compose wurstmeister/kafka未能解析kafka\u选项

jimgug · 技术社区 · sasl jaas docker-compose apache-kafka docker · 6 年前

Kafka流:通过Json日志中的键进行分组

el323 · 技术社区 · apache-kafka-streams apache-kafka java · 6 年前

如何在将保留时间设置为1秒后验证Kafka主题是否确实已清除

Sandeep Kanabar · 技术社区 · apache-kafka · 6 年前

卡夫卡:如何创建HDFS卡夫卡连接器的胖罐子?

NoName · 技术社区 · confluent-platform apache-kafka-connect apache-kafka maven java · 6 年前

kafka汇合错误java。lang.IllegalArgumentException:/tmp/confluent。缺少PVghAKRg/zookeeper/数据/myid文件

Alihossein shahabi · 技术社区 · confluent-platform apache-kafka · 6 年前

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

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

将Kafka配置为仅在127.0.0.1上公开JMX

Tobi · 技术社区 · loopback jmx local apache-kafka · 6 年前

卡夫卡服务器:尚未创建Offset的主题

Victor EStalin · 技术社区 · sarama apache-kafka go · 6 年前

由于堆OOM,kafka代理无法处理请求

user1654115 · 技术社区 · apache-kafka java · 6 年前