Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
编辑 Kafka Listener Spring 应用程序以更改阶段/目标
我可以利用另一个运行 Kafka 应用程序 代码库的团队来使用相同的数据 将其加载到我们的新暂存表中 而不是他们的 他们在 Messages 文件夹中有许多不同的 kafka 侦听器适配器 java 文件 每个文件消耗不同类型的数据 每个
ApacheKafka
kafkaconsumerapi
springKafka
Kafka - 如何同时使用过滤器和过滤器?
我有一个 Kafka 流 它从一个主题获取数据 并且需要将该信息过滤到两个不同的主题 KStream
Java
ApacheKafka
apachekafkastreams
带有安全 Kafka 抛出的 Spark 结构化流:无权访问组异常
为了在我的项目中使用结构化流 我正在 hortonworks 2 6 3 环境上测试 Spark 2 2 0 和 Kafka 0 10 1 与 Kerberos 的集成 我正在运行下面的示例代码来检查集成 我能够在 Spark 本地模式下的
Hadoop
apachespark
ApacheKafka
kerberos
kafkaconsumerapi
Kafka JDBC Sink Connector 对于具有可选字段的模式的消息给出空指针异常
Kafka JDBC Sink Connector 对于具有可选字段 parentId 的模式的消息给出空指针异常 我错过了什么吗 我正在使用开箱即用的 JSONConverter 和 JDBC Sink Connector 关于 Kafk
json
JDBC
ApacheKafka
apachekafkaconnect
confluentplatform
从副本消费
Kafka 将主题的每个分区复制到指定的复制因子 据我所知 所有写入和读取请求都会路由到分区的领导者 有没有办法从追随者那里消费而不是从领导者那里消费 Kafka中的复制只是为了故障转移吗 在 Kafka 2 3 及更早版本中 您只能从领导
ApacheKafka
kafkaconsumerapi
Kafka Streams 如何处理包含不完整数据的分区?
Kafka Streams 引擎将一个分区映射到一个工作线程 即 Java 应用程序 以便该分区中的所有消息都由该工作线程处理 我有以下场景 并试图了解它是否仍然可行 我有一个主题 A 有 3 个分区 发送给它的消息由 Kafka 随机分区
ApacheKafka
apachekafkastreams
Kafka:隔离级别的影响
我有一个用例 我需要 Kafka 分区中的 100 可靠性 幂等性 无重复消息 以及顺序保留 我正在尝试使用事务 API 来建立概念验证来实现这一目标 有一个名为 isolation level 的设置 我很难理解 In this arti
ApacheKafka
kafka消费端Offsets的一致性
我有复制因子为 3 的卡夫卡主题min insync replicas 2 一个向该主题发送 X 条消息的生产者acks all 一段时间后 1 分钟内 在所有消息发送到主题后 将使用 java kafka 客户端为此主题创建新的消费者 使
Java
ApacheKafka
kafkaconsumerapi
命名 kafka 主题的最佳实践是什么?
我们是 kafka 的新手 我们有几个团队正在开发一些相互发布 订阅事件的应用程序 由于kafka主题名称将在团队之间共享 那么命名有什么最佳实践吗 基本上我们不希望看到 A 团队命名主题companyname appname events
ApacheKafka
namingconventions
Kafka Streams 内部数据管理
在我的公司 我们广泛使用 Kafka 但出于容错的原因 我们一直使用关系数据库来存储多个中间转换和聚合的结果 现在我们正在探索 Kafka Streams 作为一种更自然的方式来做到这一点 通常 我们的需求非常简单 其中一个例子是 监听输入
ApacheKafka
apachekafkastreams
如何更改主题的起始偏移量?
是否可以更改新主题的起始偏移量 我想创建一个新主题并从偏移量开始阅读10000 How 自从卡夫卡0 11 0 0 https issues apache org jira browse KAFKA 4743你可以使用脚本kafka con
ApacheKafka
offset
Kafka 主题删除不起作用
我使用的是 Kafka 0 8 2 版本 在开发过程中 我想我可能需要删除一个主题 所以我所做的是将以下行放入服务器配置文件中并启动两个 kafka 服务器 delete topic enable true 当我需要删除一个主题并运行以下命
ApacheKafka
使用Spring Cloud Stream Kafka动态更改instanceindex
如同 在运行时更改 spring cloud stream 实例索引 计数 https stackoverflow com questions 37579939 changing spring cloud stream instance i
我可以限制kafka-node消费者的消费吗?
这看起来像我的 kafka 节点消费者 var kafka require kafka node var consumer new Consumer client 在某些情况下 获取的消息数量超出了我的处理能力 有没有办法限制它 例如每秒接
nodejs
ApacheKafka
kafka Avro 多个主题的消息反序列化器
我正在尝试以 avro 格式反序列化 kafka 消息 我使用以下代码 https github com ivangfr springboot kafka debezium ksql blob master kafka research c
Java
springboot
ApacheKafka
Avro
confluentschemaregistry
找不到 io.confluence:kafka-protobuf-serializer:6.0.0
直接的问题是 为什么 Gradle 没有解决我添加的这个依赖关系 dependencies kafka protobuf serializer implementation io confluent kafka protobuf seria
Maven
Gradle
ApacheKafka
protocolbuffers
Strimzi 运算符 Kafka 集群 ACL 未启用类型:简单
我们知道要启用Kafka ACL属性authorizer class name kafka security auth SimpleAclAuthorizer要添加到server properties但是如果 Kafka 集群由 Strim
ApacheKafka
apachekafkasecurity
strimzi
是否可以使用Kafka传输文件?
我每天都会生成数千个文件 我想使用 Kafka 进行流式传输 当我尝试读取该文件时 每一行都被视为一条单独的消息 我想知道如何将每个文件的内容作为 Kafka 主题中的单个消息 以及消费者如何将 Kafka 主题中的每条消息写入单独的文件中
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
Kafka REST 代理 API 有哪些好处?
我不知道Kafka REST Proxy API的优点 它是一个 REST API 所以我知道它对于管理来说很方便 人们为什么使用 Kafka REST 代理 API 添加对生产者或消费者的 Maven 依赖是否很麻烦 另外 我知道kafk
REST
ApacheKafka
confluentplatform
kafkarest
如何复制或配置kafka connect插件文件?
我已经从以下位置下载了插件文件https www confluence io connector kafka connect cdc microsoft sql https www confluent io connector kafka
ApacheKafka
apachekafkaconnect
1
2
3
4
5
6
...34
»