Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
无法从本地计算机连接到 Google 计算引擎上的 kafka 服务器
我正在谷歌计算引擎上运行我的动物园管理员和卡夫卡服务器 两者都在默认端口上运行 zookeeper 在 2181 上 kafka 在 9092 上 两者都在同一个实例上运行 我也打开了这两个端口 在我的 server properties
googlecomputeengine
ApacheKafka
apachezookeeper
kafka Consumer 0.9向后兼容吗?
即将推出的 kafka Consumer 0 9 x 是否会与 0 8 Broker 兼容 换句话说 是否可以只切换到新的消费者实现 而不触及其他任何东西 根据文档卡夫卡0 9 0 您不能使用新的消费者从 0 8 x 代理读取数据 原因如下
ApacheKafka
kafkaconsumerapi
Kafka Mirror Maker 无法复制 __consumer_offset 主题
我正在尝试利用镜子制造商来复制 consumer offsets主题与其他主题一起 它给出了如下所述的错误 2018 10 24 16 16 03 802 ERROR 向主题发送消息时出错 consumer offsets 键 16 字节
ApacheKafka
confluentplatform
mirroring
consumer
保留配置 offsets.retention.minutes 和 log.retention.months 之间的区别
以下两种保留配置有什么区别 offsets retention minutes log retention minutes 我不明白它们之间有何不同或相互关联 根据我的理解 一旦删除偏移量 日志中的记录就无法访问 反之亦然 我有什么误解吗
ApacheKafka
retention
Kafka JDBC Sink 连接器:未分配任务
我尝试使用以下配置启动 JDBC 接收器连接器 name crm data sink hh config connector class io confluent connect jdbc JdbcSinkConnector tasks m
ApacheKafka
apachekafkaconnect
Kafka Spring 集成:Kafka 消费者未收到标头
我正在使用 Kafka Spring Integration 使用 kafka 发布和消费消息 我看到有效负载已正确从生产者传递到消费者 但标头信息在某处被覆盖 ServiceActivator inputChannel fromKafka
Spring
springintegration
ApacheKafka
如何更改Kafka主题的副本数量?
生产者或管理员创建 Kafka 主题后 如何更改该主题的副本数量 要增加给定主题的副本数量 您必须 1 在自定义重新分配 json 文件中指定额外副本 例如 您可以创建增加复制因子 json并将此内容放入其中 version 1 parti
ApacheKafka
我们可以在 mongodb 中更新/更新记录吗?数据源是kafka
我们可以更新 更新插入 mongodb 中的记录 但是是否有任何方法或函数可以让我们直接在 mongodb 中更新或更新插入文档 并且源系统是 kafka 目标系统是 mongodb 是的 我们可以更新 更新插入数据 要更新 您必须在 Ka
ApacheKafka
apachekafkaconnect
mongodbkafkaconnector
Kafka如何读取__consumer_offsets主题
我正在尝试找出我当前的高级消费者正在发挥哪些作用 我使用 Kafka 0 8 2 1 noKafka 的 server properties 中设置的 offset storage 我认为这意味着偏移量存储在 Kafka 中 我还通过在 Z
ApacheKafka
kafkaconsumerapi
Kafka 生产者无法发送消息,出现 NOT_LEADER_FOR_PARTITION 异常
我们使用 spring cloud stream binder kafka 3 0 3 RELEASE 将消息发送到我们的 Kafka 集群 2 4 1 生产者线程之一时不时地收到 NOT LEADER FOR PARTITION 异常 甚
Java
ApacheKafka
springcloudstream
Kafka Connect 接收器任务忽略容差限制
我尝试忽略接收器连接器中的错误消息errors tolerance all选项 完整的连接器配置 name crm data sink pandora config connector class io confluent connect
ApacheKafka
apachekafkaconnect
在kafka中,当使用事务生成消息时,消费者偏移量增加了一倍
我正在使用 spring boot 2 kafka 2 2 0 spring kafka 2 2 5 制作项目 I maked kafka exactly once环境以及消息的产生和消费都很好 BUT kafka consumer gro
Java
ApacheKafka
springKafka
如何在 spring-boot 应用程序启动期间创建多个 kafka 主题?
我有这样的配置 Configuration public class KafkaTopicConfig private final TopicProperties topics public KafkaTopicConfig TopicPr
Spring
springboot
ApacheKafka
springKafka
springconfig
Kafka I/O 错误 java.io.EOFException: null
我正在使用 Kafka 0 8 2 0 Scala 2 10 在我的日志文件中 我间歇性地看到以下消息 这似乎是一个连接问题 但我正在本地主机中运行这两个问题 这是无害的警告消息还是我应该采取措施来避免它 2015 10 30 14 12
ApacheKafka
如何使用 spring-kafka 暂停和恢复 @KafkaListener
我已经实现了 Kafka 消费者 现在我有了一个场景 通过Spring Boot从Kafka流中读取数据2 2 5 Release 加载数据库表1 将表1的数据复制到表2 清空表格1 要执行上述操作 我需要使用使用quartz的调度作业 已
Java
springboot
ApacheKafka
springKafka
从 Kafka 多次读取同一条消息
I use 春季卡夫卡 API通过手动偏移量管理来实现 Kafka 消费者 KafkaListener topics some topic public void onMessage Payload Message message Ackn
Java
Spring
ApacheKafka
kafkaconsumerapi
springKafka
“kafka.zookeeper.ZooKeeperClientTimeoutException:等待连接超时”仅在列出主题期间
我发现了一些主题相似但上下文不同的问题 我可以连接以创建主题 但无法列出主题 因为我收到了下面提到的错误 据我所知 人们在我时面临基本连接问题 我只是为了列出主题列表 如果重要的话 这是我的docker compose yml versio
Docker
ApacheKafka
dockercompose
apachezookeeper
如何仅在窗口完成时输出窗口聚合结果? [复制]
这个问题在这里已经有答案了 我有一个KStream我想在其中计算事件的某些维度 我这样做 KTable
ApacheKafka
apachekafkastreams
Kafka - 反序列化消费者中的对象
我们正在考虑在我们的消息传递中使用 Kafka 并且我们的应用程序是使用 Spring 开发的 所以 我们打算使用spring kafka 生产者将消息作为 HashMap 对象放入队列中 我们有 JSON 序列化器 并且假设映射将被序列化
Java
ApacheKafka
springKafka
Debezium:数据库中没有记录最大LSN;请确保 SQL Server 代理正在运行
这个问题与 Debezium 如何使用 Kafka Connect 正确注册 SqlServer 连接器 连接被拒绝 在 Windows 10 中 我在 Docker 容器外部的 Microsoft SQL Server 实例上运行 Deb
sqlserver
ApacheKafka
apachekafkaconnect
debezium
«
1 ...
28
29
30
31
32
33
34
»