代码之家 › 专栏 › 技术社区 › Raman

卡夫卡流:转发到主题后清除对象

apache-kafka-streams apache-kafka

Raman · 技术社区 · 6 年前

假设值是字符串或类对象。

context.forward(key, value, topic);

value = null;

1 回复 | 直到 6 年前

Matthias J. Sax 6 年前

很好,因为你在传递推荐信。如果 value 将是基元类型(此API不可能),值将被复制也可以。

修改传递的对象(不可能与 String set() 之后 context.forward 集合() 将修改先前转发的POJO。这可能会导致问题。

推荐文章

elenwen · 在配置中发现未知的功能门KafkaNodePools

5 月前

ljuk · 连接器启动时的Debezium信号表

1 年前

Shubham Snehi · Golang Segmentation在消费者组迁移时获得一半分区

1 年前

RushHour · 无法定义Kafka配置的卷以便使用docker通过CLI启动生产者

1 年前

Hossein Rouhi · 优化Docker中的Kafka性能:单个ZooKeeper与多个、Broker计数的影响

1 年前

Narut Promsuparoj · Kafka连接器时间戳转换器与SMT一起使用时不工作

1 年前

user23351472 · 从卡夫集群中移除Broker的正确方法

1 年前

Varun Sharma · 从Kaffa主题消费并添加到列表中

1 年前

zloodeyka · Confluent rest prozy基本身份验证不起作用

1 年前

Kumar Saras · 我可以在Kafka Streams拓扑和普通Kafka消费者之间使用相同的组id吗?

1 年前