xmar - 代码之家

ClickHouse:如何从物化视图中删除*AggregatingMergeTree表

xmar · 技术社区 · clickhouse · 5 年前

卡夫卡流:如何在申请再加工之前获得补偿限额以及如何停止

xmar · 技术社区 · apache-kafka-streams apache-kafka · 5 年前

卡夫卡在重新分配分区工具和进度上卡住了

xmar · 技术社区 · apache-kafka · 5 年前

ClickHouse Kafka引擎可以使用压缩的JSON消息吗?

xmar · 技术社区 · clickhouse apache-kafka json · 5 年前

ClickHouse Kafka Engine:如何为KafkaEngine升级Kafka消费者版

xmar · 技术社区 · clickhouse apache-kafka · 5 年前

Kafka流:topic.compression.type不是已知配置

xmar · 技术社区 · apache-kafka-streams apache-kafka java · 5 年前

Kafka Streams子会话:通过数据子集进行会话并聚合回

xmar · 技术社区 · apache-kafka-streams apache-kafka · 5 年前

Kafka流:是否可以使用不同的时间戳进行删除,而不是流处理?

xmar · 技术社区 · apache-kafka-streams apache-kafka · 5 年前

卡夫卡流:重新处理应用程序协调

xmar · 技术社区 · stream-processing apache-kafka-streams apache-kafka architecture · 5 年前

Clickhouse:select上的分割输出

xmar · 技术社区 · clickhouse apache-kafka · 6 年前

卡夫卡:添加一批旧数据

xmar · 技术社区 · stream-processing apache-kafka-streams apache-kafka · 6 年前

卡夫卡流:混合和匹配PAPI和DSL KTable不可共分

xmar · 技术社区 · embedded-kafka apache-kafka-streams scalatest apache-kafka · 6 年前

Kafka Streams:不重新分区共分区数据的映射

xmar · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

卡夫卡:防止删除重新处理的过去事件

xmar · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

从MongoDB迁移到ClickHouse:非规范化和嵌套实体

xmar · 技术社区 · clickhouse mongodb · 6 年前

clickhouse/kafka:将json对象类型读入字段

xmar · 技术社区 · clickhouse apache-kafka json · 6 年前

如何使用处理器api访问dsl创建的ktable/globalktable?

xmar · 技术社区 · apache-kafka-streams · 6 年前

代理失败后,kafkastreams应用程序从一开始就重新处理

xmar · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

kafka-consumer-groups.sh何时将当前“偏移量”显示为“-”?

xmar · 技术社区 · apache-kafka-streams kafka-consumer-api partitioning apache-kafka · 6 年前

kafka streams papi:processor close在启动时被调用,而且太频繁

xmar · 技术社区 · apache-kafka-streams apache-kafka scala · 6 年前

Kafka流式消费群并发:仅从一个分区消费?

xmar · 技术社区 · apache-kafka-streams amazon-ecs apache-kafka docker · 6 年前

卡夫卡流:有没有可能对州商店有“压缩,删除”的政策?

xmar · 技术社区 · apache-kafka-streams apache-kafka · 6 年前

如何在带有存储和处理器API的Kafka流中实现GDPR忘记(删除)权限?

xmar · 技术社区 · apache-kafka-streams partitioning streaming apache-kafka · 6 年前

喷涂JSON:柔性阵列/对象

xmar · 技术社区 · spray-json json-deserialization scala json · 6 年前

在SBT中重命名程序集生成的uberjar

xmar · 技术社区 · uberjar sbt-assembly sbt jar scala · 6 年前