Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何删除/清除 Kafka Streams 中的状态存储?
我有一个习惯Transformer在我的 kafka streams DSL 的末尾实现 并带有持久的变更日志KeyValueStore绑定到它 几周以来 我在商店里放了太多的数据 现在 每当我加载应用程序时 它就会消耗太多的内存 然而 应
ApacheKafka
apachekafkastreams
Spring Apache Kafka onFailure KafkaTemplate 的回调未因连接错误而触发
我目前正在 Spring Boot 应用程序中对 Apache Kafka 进行大量实验 我当前的目标是编写一个接收一些消息负载的 REST 端点 它将使用 KafkaTemplate 将数据发送到在端口 9092 上运行的本地 Kafka
springboot
ApacheKafka
springKafka
用于 Azure Blob 存储的 Kafka 连接器
我需要将推送到 Kafka 的消息存储在深度存储中 我们正在使用 Azure 云服务 因此我认为 Azure Blob 存储可能是更好的选择 我想使用 Kafka Connect 的接收器连接器 API 将数据推送到 Azure Blob
ApacheKafka
azureblobstorage
apachekafkaconnect
当目标系统关闭时,停止 Spring Cloud Stream @StreamListener 监听
我有一个应用程序 它从 Kafka 获取消息并调用目标系统来更新旧版 Oracle 数据库 我想要启用一个场景 如果目标系统关闭 则将消息留在 Kafka 总线上 并且在给定的时间内不处理它们 我正在考虑一些基于 Hystrix 的断路器解
ApacheKafka
Hystrix
springcloudstream
springretry
circuitbreaker
有没有办法从 Kafka 主题获取最后一条消息?
我有一个具有多个分区的 Kafka 主题 我想知道 Java 中是否有一种方法可以获取该主题的最后一条消息 我不关心分区 我只想获取最新消息 我努力了 KafkaListener但它仅在主题更新时才获取消息 如果应用程序打开后没有发布任何内
Java
ApacheKafka
springKafka
无法解码Spring云流DefaultKafkaHeaderMapper中的json类型
我们正在使用 spring cloud stream 并计划升级我们的 Kafka 版本 我们的应用程序使用spring cloud stream 2 0 0 spring kafka 2 1 7 与 apache kafka 服务器1 0
您如何知道 Kafka 代理上的主题何时创建?
你怎么知道Kafka中的主题是什么时候创建的 似乎有一些主题是使用错误数量的分区创建的 有没有办法知道主题的创建日期 据说 创建了一个名为 test 的主题n分区数 如何找到在 Kafka 上创建此 测试 主题的日期和时间 可以看到Kafk
ApacheKafka
无法从客户端会话 ID 读取附加数据
我们有hadoop集群3 kafka机器和3 动物园管理员 servers hadoop 版本 2 6 4 HORTONWORKS 在zookeeper日志下 var log zookeeper 我们看到了一百万条警告消息 例如 2019
ApacheKafka
apachezookeeper
hdp
在 Linux 上使用 confluence-kafka-go 构建 Go 应用程序
我正在尝试使用我的 go 应用程序创建一个 docker 映像 该应用程序 在 MacOS 上开发 取决于confluent kafka go这又取决于librdkafka dev我将其安装在 Docker 映像中 如下所示 FROM go
Docker
go
ApacheKafka
如何使用 docker-compose 而不是使用 docker 桥从 docker 容器连接到 localhost:9092
我正在我的上运行 Kafka 服务器本地机器在端口 9092 上 我正在运行一项服务使用 docker compose 的 docker 容器需要向kafka服务器发送消息 我尝试使用 localhost 和 IP 在服务代码中编写我的生产
Docker
ApacheKafka
dockercompose
无法在 Kafka 中使用来自远程计算机的消息
我在我的一台机器上创建了一个kafka主题 其IP为192 168 25 50 主题名称为test poc 然后通过使用 kafka console Producer 我生成了如下消息 kafka console producer brok
ApacheKafka
kafkaconsumerapi
在Kafka集群中添加新的ZooKeeper节点?
我正在运行一个包含五个节点的 Apache Kafka 集群 并且正在使用一个包含三个节点的 Apache ZooKeeper 集群 在zookeeper properties文件中 server 1 zNode01 2888 3888 s
ApacheKafka
apachezookeeper
Kafka AVRO - 从长时间到日期时间的转换
当我想要发送包含 long 类型字段的 AVRO 消息时 出现以下错误 Caused by org apache kafka common errors SerializationException Error deserializing
ApacheKafka
deserialization
Avro
confluentplatform
AVRO 原始类型的 Serde 类
我正在用 Java 编写一个 Kafka 流应用程序 它接受由连接器创建的输入主题 该连接器使用架构注册表和 avro 作为键和值转换器 连接器生成以下模式 key schema int value schema type record n
Java
ApacheKafka
Avro
apachekafkastreams
confluentplatform
java.lang.IllegalArgumentException kafka控制台消费者
我们在我们的环境中使用 Kafka 2 10 0 9 0 2 4 2 0 258 我们在 kafka 控制台消费者的几个主题上遇到了以下异常 我知道有时进入这些主题的消息太大 但它们不会超过 message max bytes kafka
ApacheKafka
MSK 不删除旧消息
我有三个 MSK 集群 开发 非产品和产品 它们都具有以下集群配置 没有主题级别配置 auto create topics enable false default replication factor 3 min insync repli
ApacheKafka
awsmsk
Kafka-Connect:分布式模式下创建新的连接器就是创建新的组
我目前正在使用 confluence 3 0 1 平台 我试图在两个不同的工作人员上创建 2 个连接器 但尝试创建一个新的连接器正在为其创建一个新组 Two connectors were created using below detai
elasticsearch
ApacheKafka
apachekafkaconnect
confluentplatform
在 Apache Kafka 中,为什么消费者实例不能多于分区?
我正在学习卡夫卡 阅读这里的介绍部分 https kafka apache org documentation html introduction https kafka apache org documentation html intr
Distributed
ApacheKafka
从客户端检索 Kafka 代理属性
我想知道是否有一种方法可以使用 shell 命令检索 kafka 代理的所有配置属性 例如 类似的东西 kafka configs sh zookeeper broker ip 2181 entity type brokers descri
ApacheKafka
Amazon S3 可以作为 Kafka 集群的源吗?
Amazon S3 可以用作 Kafka 集群中的接收器 我想检查 Amazon S3 是否可以用作 Kafka 集群的源 卡夫卡连接 文件系统连接器 http kafka connect fs readthedocs io en late
amazons3
ApacheKafka
kafkaproducerapi
apachekafkaconnect
«
1 ...
26
27
28
29
30
31
32
...38
»