Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如果将新分区添加到 Kafka 主题,消费者偏移量会发生什么?
当添加新分区时 消费者偏移量会发生什么 它保持不变吗 是的 它保持不变 为每个分区单独维护一个偏移量 因此您的新分区的偏移量将从 0 开始 并且不会影响其他偏移量
ApacheKafka
从外部连接kafka的问题
我正在使用 hortonwork Sandbox 作为 kafka 服务器 尝试使用java代码从eclipse连接kafka 使用此配置连接到生产者发送消息 metadata broker list sandbox hortonworks
Hadoop
Cloudera
ApacheKafka
hortonworksdataplatform
Python Kafka 消费者缺少轮询一些消息
我的 Kafka 消费者的代码如下所示 def read messages from kafka topic my topic consumer KafkaConsumer bootstrap servers my host1 my hos
python
ApacheKafka
如何让 IntelliJ IDEA 加载 org.slf4j.impl.StaticLoggerBinder 来运行 Kafka?
我想从 IDEA 运行 Kafka 但收到以下错误 gt Task core Kafka main SLF4J Failed to load class org slf4j impl StaticLoggerBinder SLF4J Def
Java
scala
Gradle
intellijidea
ApacheKafka
Kafka 到 hdfs3 接收器缺少所需配置“confluence.topic.bootstrap.servers”,该配置没有默认值
Status 我的HDFS是通过ambari HDP安装的 我目前正在尝试将 kafka 主题加载到 HDFS 接收器中 Kafka 和 HDFS 安装在同一台机器 x x x x 上 除了根据我的需要更改一些端口之外 我没有对默认设置进行
ApacheKafka
HDFS
apachekafkaconnect
confluentplatform
将连接器添加到 Kafka Connect
我正在使用 Confluence Kafka Docker 镜像 特别是使用这个 https github com confluenceinc cp docker images tree 4 0 x examples cp all in o
jar
ApacheKafka
apachekafkaconnect
Spark结构化流仅从Kafka的一个分区获取消息
我遇到了这样一种情况 spark 只能从 Kafka 2 分区主题的一个分区进行流式传输和获取消息 我的主题 C bigdata kafka 2 11 0 10 1 1 bin windows gt kafka topics create
apachespark
ApacheKafka
SparkStructuredStreaming
如何使用 kafka 使用 python 连接 JDBC 接收器和源
我想从一个系统直播到另一个系统 我正在使用 kafka python 并且能够在本地进行直播 发现连接器可以处理多个设备 有人可以建议我一种使用连接器在 python 中实现它的方法吗 Kafka Connect 是一个 Java 框架 而
ApacheKafka
apachekafkaconnect
kafkapython
当 springboot 应用程序在 docker 容器上运行时,无法找到 LoginModule 类:org.apache.kafka.common.security.plain.PlainLoginModule
我有一个 Spring Boot 应用程序使用spring kafka向 kafka 发布消息的依赖 kafka 配置使用标准 kafka properties sasl jaas config 对 kafka 服务器进行身份验证 应用程序
Java
ApacheKafka
卡夫卡|增加多个主题的复制因子
我有一个 3 代理 Kafka 集群 其中有许多主题 复制因子为 1 我知道我可以通过将带有分区重新分配配置的 JSON 文件传递 给kafka reassign partitions sh 我的困惑是 我应该传递一个包含所有主题的分区重新
ApacheKafka
是否可以在 Confluence KSQL 查询中使用多个左连接?尝试加入超过 1 个表的流,如果没有,那么解决方案是什么?
溪流 describe ammas Field Type ROWTIME BIGINT system ROWKEY VARCHAR STRING system ID INTEGER 对于运行时统计信息和查询详细信息 运行 DESCRIBE
ApacheKafka
confluentplatform
ksqldb
Java Apache Kafka Producer 元数据更新器和重试逻辑
我正在使用 Spring for Apache Kafka 并创建了一个服务 该服务通过 Spring 的 KafkaTemplate 使用 Kafka Producer org apache kafka clients Producer
ApacheKafka
kafkaproducerapi
变更日志/重新分区主题的复制因子应该是多少
我知道可以为 kafka 流配置复制因子这些内部主题 我们的应用程序用于复制因子为 3 的普通应用程序主题 但到目前为止我还没有为变更日志 重新分区主题配置复制因子 而我的假设是如果一个经纪人死亡 或由于某种原因领导者发生变化 kafka
ApacheKafka
apachekafkastreams
Debezium PostgreSQL 连接器未创建主题
当我使用启动 Debezium 连接器用于 PostgreSQL 时 未创建 Kafka 主题 这是我的属性文件中的内容 name testdb connector class io debezium connector postgresq
postgresql
ApacheKafka
debezium
确定 Kafka-Client 与 kafka-broker 的兼容性
在远程 kafka 云集群中 kafka 代理将更新到新版本 5 1 因此应用新的 kafka 协议 现在我应该更新我的 kafka 客户端以便能够连接 现在我在我的 spring boot 应用程序中使用以下 kafka 相关依赖项
Java
ApacheKafka
springKafka
java.lang.IllegalArgumentException:Jetty ALPN/NPN 尚未正确配置
Getting java lang IllegalArgumentException Jetty ALPN NPN has not been properly configured 同时使用gRPC google pub sub 发布 消费
Java
springboot
ApacheKafka
classLoader
gRPC
如果第一个经纪人宕机,Kafka 消费者将无法消费
我正在使用最新版本的kafka kafka 2 12 1 0 0 tgz 我已经设置了带有 3 个代理的简单集群 只是在每个实例的属性文件中更改了broker id 1 和listeners PLAINTEXT 9092 集群启动后 我使用
ApacheKafka
failover
consumer
是否可以反序列化 Avro 消息(使用来自 Kafka 的消息)而不在 ConfluenceRegistryAvroDeserializationSchema 中提供 Reader 模式
我在 Apache Flink 中使用 Kafka Connector 来访问由汇流卡夫卡 除了 schema 注册表 url 之外ConfluentRegistryAvroDeserializationSchema forGeneric
ApacheKafka
apacheflink
confluentschemaregistry
如何将 Spark Streaming DF 写入 Kafka 主题
我正在使用 Spark Streaming 处理两个 Kafka 队列之间的数据 但我似乎找不到从 Spark 写入 Kafka 的好方法 我已经尝试过这个 input foreachRDD rdd gt rdd foreachPartit
scala
apachespark
ApacheKafka
SparkStreaming
sparkstreamingkafka
如何有效地将我的@KafkaListener绑定到ConcurrentKafkaListenerContainerFactory?
我遇到了这个对我来说似乎很奇怪的场景 所以基本上我定义了两个 KafkaListener在一堂课中 KafkaListener id listener1 idIsGroup false topics data1 containerFacto
springboot
ApacheKafka
springKafka
«
1 ...
30
31
32
33
34
35
36
...38
»