Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Kafka JDBC Sink Connector 对于具有可选字段的模式的消息给出空指针异常
Kafka JDBC Sink Connector 对于具有可选字段 parentId 的模式的消息给出空指针异常 我错过了什么吗 我正在使用开箱即用的 JSONConverter 和 JDBC Sink Connector 关于 Kafk
json
JDBC
ApacheKafka
apachekafkaconnect
confluentplatform
Kafka REST 代理 API 有哪些好处?
我不知道Kafka REST Proxy API的优点 它是一个 REST API 所以我知道它对于管理来说很方便 人们为什么使用 Kafka REST 代理 API 添加对生产者或消费者的 Maven 依赖是否很麻烦 另外 我知道kafk
REST
ApacheKafka
confluentplatform
kafkarest
带有 kafka-avro-console-consumer 的未知魔法字节
我一直在尝试将 Confluence 中的 kafka avro console consumer 连接到我们的旧版 Kafka 集群 该集群是在没有 Confluence Schema Registry 的情况下部署的 我使用以下属性显式
ApacheKafka
Avro
confluentplatform
confluentschemaregistry
Kafka 连接教程停止工作
我在此链接中执行了步骤 7 使用 Kafka Connect 导入 导出数据 http kafka apache org documentation html quickstart http kafka apache org documen
Kafka Streams 在 HDFS 上查找数据
我正在使用 Kafka Streams v0 10 0 1 编写一个应用程序 并希望通过查找数据来丰富我正在处理的记录 该数据 带时间戳的文件 每天 或每天 2 3 次 写入 HDFS 目录 我怎样才能将其加载到Kafka Streams应
无法启动动物园管理员
我正在使用合流平台 zookeeper 处于活动状态查找状态 但是当我尝试用 confluence 启动 kafka 时 它显示 Zookeeper 已关闭 sudo service zookeeper status Redirecting
ApacheKafka
apachezookeeper
confluentplatform
Kafka消费者启动延迟汇合dotnet
当启动 confluence dotnet Consumer 时 在调用订阅和后续轮询之后 似乎需要很长时间才能从服务器接收 分区已分配 事件 因此也需要很长时间 大约 10 15 秒 起初我以为存在自动创建主题的开销 但无论消费者的主题
c
ApacheKafka
kafkaconsumerapi
confluentplatform
Kafka s3 连接“值不是结构类型”错误
我使用以下参数加载 s3 连接器 confluent load s3 sink name s3 sink config connector class io confluent connect s3 S3SinkConnector task
ApacheKafka
apachekafkaconnect
confluentplatform
在 Windows 中启动 Confluence Schema Registry
我有Windows环境和我自己的一套kafka和zookeeper正在运行 为了使用自定义对象 我开始使用 Avro 但我需要启动注册表 下载 Confluence 平台并运行 bin schema registry start etc s
由于 libssl 依赖,`apt-get install librdkafka1` 在 Debian 9.x 上失败
Basic apt get install librdkafka1在 Debian 8 x 上工作 但在 Debian 9 x 上失败 这看起来像是关于 libssl 的依赖版本问题 Debian 8 x 有 libssl1 0 0 Deb
Debian
ApacheKafka
confluentplatform
Kafka 连接集群设置或启动连接工作线程
我正在通过 kafka connect 我正在尝试了解这些概念 假设我已经设置了 kafka 集群 节点 k1 k2 和 k3 并且它正在运行 现在我想在不同节点 例如 c1 和 c2 中以分布式模式运行 kafka 连接工作程序 几个问题
ApacheKafka
apachekafkaconnect
confluentplatform
检索 id 1 的 Avro 模式时出错,未找到主题。;错误代码:40401
Caused by org apache kafka common errors SerializationException Error retrieving Avro schema for id 1 Caused by io confl
ApacheKafka
Avro
confluentplatform
confluentschemaregistry
卡夫卡偏移量管理
我们正在使用 Kafka 0 10 我在网上 和文档中 看到了一些相互矛盾的信息 这些信息涉及当enable auto commit 为 TRUE 时如何在 kafka 中管理偏移量 检索消息的同一个 poll 方法是否也按配置的时间间隔处
ApacheKafka
kafkaconsumerapi
confluentplatform
使用带有 Helm 安装的 Kafka/Confluence 的连接器
我已经使用 Helm 图表在本地 Minikube 上安装了 Kafkahttps github com confluenceinc cp helm charts https github com confluentinc cp helm
mysql
Kubernetes
ApacheKafka
apachekafkaconnect
confluentplatform
Windows 中的 Confluence 平台
是否可以在 Windows 上运行完整的 Confluence 平台 如果不是 运行 Confluence 平台的最佳方式是什么 Thanks Per 支持的操作系统列表 https docs confluent io current in
Windows
ApacheKafka
confluentplatform
卡夫卡生产者在第一条消息上速度很慢
我在 NET 中有一个测试应用程序 它创建 kafka 生产者并使用 Confluence 客户端库向主题发送一些消息 由于某种原因 第一条消息的确认总是晚 1 秒到达 后续消息的确认几乎立即到达 这是正常行为还是我缺少某些配置 我想我尝试
NET
ApacheKafka
confluentplatform
以 JSON 格式将数据从 Kafka Topic 推送到 PostgreSQL
更新后出错 2019 07 29 12 52 23 301 INFO Initializing writer using SQL dialect PostgreSqlDatabaseDialect io confluent connect
postgresql
ApacheKafka
apachekafkaconnect
confluentplatform
KSQL 流 - 从结构数组中获取数据
我的 JSON 看起来像 Obj1 a abc b def c ghi ArrayObj key1 1 Key2 2 Key3 3 key1 4 Key2 5 Key3 6 key1 7 Key2 8 Key3 9 我已经编写了 KSQL
ApacheKafka
ksqldb
confluentplatform
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
1
2
»