英文: Use kafka-avro-console-producer with a schema already in the schema registry 问题 我想使用带有模式注册表的kafk...
Kafka – 如果分区丢失,如何恢复?
英文: Kafka - How to recover if a partition is lost? 问题 我有一个Kafka集群,有4个节点,一个主题分成了40个分区,复制因子为2。Kafka版本是...
Kafka KStream到KStream的连接 | 重新启动性能
英文: Kafka KStream to KStream join | restart performance 问题 我计划将两个主题作为KStreams加入到一个长窗口(约1周)中。假设在这个窗口中...
CMD does not run if used after ENTRYPOINT.
英文: CMD does not run if used after ENTRYPOINT 问题 我有以下的Docker文件 FROM confluentinc/cp-kafka-connect:5....
KeyValueStore 如何允许写操作(Kafka Streams)
英文: How KeyValueStore allows write operations (Kafka Streams) 问题 我正在尝试理解Kafka Stream的StateStore。我理解了...
在Kafka生产者中有两种不同类型的分区。
英文: Two different types of partitions in kafka producer 问题 在Kafka生产者中,我正在发送两组不同的数据。我有一个主题的两个分区。第一个带有...
使用Kafka Go客户端的Consumer,如何倒带并查看分区中的先前偏移量?
英文: How to rewind and look at previous offset in a partition using Kafka Go client's Consumer 问题...
how to access kafka installed in docker with golang on host
英文: how to access kafka installed in docker with golang on host 问题 我需要使用Golang访问Kafka,所以我在Docker中安装了...
为什么在Shopify Sarama消费者中需要分区来消费消息?
英文: Why partition is needed in Shopify Sarama consumer to consume messages 问题 很抱歉,我只能为你提供翻译服务,无法回答关于...
How to create a kafka consumer group in Golang?
英文: How to create a kafka consumer group in Golang? 问题 一个可用的库是sarama(或其扩展sarama-cluster),然而在sarama和s...
41