Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
我的 kafka docker 容器无法连接到我的 Zookeeper docker 容器
我想同时使用confluent kafka and confluent zookeeper并在单个 Ubuntu 服务器上运行它们 我正在使用以下配置 docker run e ZOOKEEPER CLIENT PORT 2181 name
Docker
ApacheKafka
apachezookeeper
Kafka消费者位置()与承诺()?
我不明白javadoc中的KafkaConsumerposition 和commited 方法之间的区别 位置 公开多仓 TopicPartition分区 获取将要获取的下一条记录的偏移量 如果存在具有该偏移量的记录 坚定的 获取给定分区的
ApacheKafka
kafkaconsumerapi
java.lang.IllegalStateException:读取增量文件时出错,使用 kafka 进行 Spark 结构化流处理
我在我们的项目中使用结构化流 Kafka 进行实时数据分析 我使用的是 Spark 2 2 kafka 0 10 2 我在应用程序启动时从检查点进行流式查询恢复期间遇到问题 由于单个 kafka 流点派生有多个流查询 并且每个流查询都有不同
ApacheKafka
apachespark20
SparkStructuredStreaming
checkpoint
批量消费骆驼kafka
尽管遵循此处发布的示例 但我无法与卡夫卡骆驼消费者一起批量阅读 我是否需要对生产者进行更改 或者问题最有可能出在我的消费者配置上 有问题的应用程序利用卡夫卡骆驼组件 https camel apache org components 3 1
Java
ApacheKafka
apachecamel
Kafka - 无法建立与节点-1的连接
我正在尝试使用 apache flink 流处理 kafka 主题 但我遇到了这个问题 2018 04 10 02 55 59 856 ProducerConfig values acks 1 batch size 16384 bootst
ApacheKafka
apacheflink
具有 json 模式的 Kafka jdbc 接收器连接器无法正常工作
使用最新的 kafka 和 confluence jdbc 接收器连接器 发送一条非常简单的 Json 消息 schema type struct fields type int optional false field id type s
json
JDBC
ApacheKafka
apachekafkaconnect
Flink:将文件与kafka流连接
我有一个问题我真的无法弄清楚 所以我有一个 kafka 流 其中包含一些如下数据 adId 9001 eventAction start eventType track eventValue timestamp 1498118549550
ApacheKafka
apacheflink
多个消费者从单个 kafka 分区消费
我读到以下内容卡夫卡文档 https kafka apache org intro intro consumers Kafka 中实现消费的方式是将日志中的分区划分到消费者实例上 以便每个实例在任何时间点都是 公平份额 分区的独占消费者 K
ApacheKafka
kafkaconsumerapi
如何从 Kafka 主题获取最近的消息
我们是否有任何选项 例如从 Kafka 主题获取最近 10 20 等消息 我可以看到 from beginning 选项从主题中获取所有消息 但如果我只想获取第一个 最后一个 中间或最新的几条消息 10 我们有一些选择吗 前 N 条消息 您
ApacheKafka
kafkaconsumerapi
无法使用传入消息调用 Kafka Listener 方法
我使用 Spring Boot 应用程序在 Kafka Producer 中将其转换为 toString 来发送 JSON 数组 但在 Consumer 中收到以下错误 org springframework kafka listener
Spring
springboot
ApacheKafka
kafkaconsumerapi
Kafka Connect 无法通过 SSL 读取 Kafka 主题
在我们的 docker swarm 中运行 kafka connect 并使用以下 compose 文件 cp kafka connect node image confluentinc cp kafka connect 5 1 0 por
SSL
ApacheKafka
apachekafkaconnect
@SentTo 如何将消息发送到相关主题?
我在 Rest 控制器中使用 ReplyingKafkaTemplate 来返回同步响应 我还设置了标头 REPLY TOPIC 对于监听器微服务部分 KafkaListener topics kafka topic request top
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
springKafka
卡夫卡偏移量管理
我们正在使用 Kafka 0 10 我在网上 和文档中 看到了一些相互矛盾的信息 这些信息涉及当enable auto commit 为 TRUE 时如何在 kafka 中管理偏移量 检索消息的同一个 poll 方法是否也按配置的时间间隔处
ApacheKafka
kafkaconsumerapi
confluentplatform
我们可以在 Spring Boot 中使用多个 kafka 模板吗?
在我的 spring boot kafka 发布者应用程序中 我想提供对以 String json 或字节格式发布消息的支持 因为我想同时提供对 json 和 avro 的支持 但是 Spring Boot 中的 Kafka 模板让我们只定
ApacheKafka
springKafka
kafkaproducerapi
我们可以仅对 kafka 禁用 log4j 日志吗
我正在使用以下属性Log4j log4j properties log4j rootLogger DEBUG stdout log4j appender stdout org apache log4j ConsoleAppender log
ApacheKafka
apachekafkastreams
无法使用 .\bin\windows\kafka-server-start.bat .\config\server.properties cmd 启动 kafka
我已经使用以下链接预先配置了zookeeper和kafka https dzone com articles running apache kafka on windows os https dzone com articles runni
ApacheKafka
wmic
Kafka中的延迟消息消费
如何使用 Apache Kafka 生成 消费延迟消息 似乎标准 Kafka 和 Java kafka client 功能没有此功能 我知道我可以用标准的等待 通知机制自己实现它 但它看起来不太可靠 因此任何建议和良好实践都值得赞赏 Fou
ApacheKafka
kafkaconsumerapi
Kafka以相反的顺序消费消息
我使用Kafka 0 10 我有一个主题logs我的物联网设备将日志发布到其中 我的消息的关键是device id 所以同一设备的所有日志都在同一个分区 我有一个 API devices id tail logs需要显示呼叫时某台设备的最后
ApacheKafka
kafkaconsumerapi
在模式注册表中,消费者的模式可能与生产者的模式不同,这实际上意味着什么
在向 Kafka 生成 AVRO 数据时 Avro 序列化程序在写入数据时使用的字节数组中写入相同的架构 ID Kafka Consumer 根据接收到的字节数组中的模式 ID 从模式注册表中获取模式 因此 生产者和消费者等模式都使用相同的
ApacheKafka
Avro
kafkaproducerapi
confluentschemaregistry
从 Kafka 获取最新值
我有一个卡夫卡主题叫做A 主题中的数据格式A is id 1 name stackoverflow created at 2017 09 28 22 30 00 000 id 2 name confluent created at 2017
ApacheKafka
apachekafkastreams
ksqldb
«
1 ...
18
19
20
21
22
23
24
...40
»