kafka Punctuator 源码

2022-10-20
浏览 (241)

kafka Punctuator 代码

文件路径：/streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements. See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License. You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.kafka.streams.processor;

import java.time.Duration;
import org.apache.kafka.streams.processor.api.Record;

/**
 * A functional interface used as an argument to {@link ProcessorContext#schedule(Duration, PunctuationType, Punctuator)}.
 *
 * @see Cancellable
 */
public interface Punctuator {

    /**
     * Perform the scheduled periodic operation.
     *
     * <p> If this method accesses {@link ProcessorContext} or
     * {@link org.apache.kafka.streams.processor.api.ProcessorContext}, record metadata like topic,
     * partition, and offset or {@link org.apache.kafka.streams.processor.api.RecordMetadata} won't
     * be available.
     *
     * <p> Furthermore, for any record that is sent downstream via {@link ProcessorContext#forward(Object, Object)}
     * or {@link org.apache.kafka.streams.processor.api.ProcessorContext#forward(Record)}, there
     * won't be any record metadata. If {@link ProcessorContext#forward(Object, Object)} is used,
     * it's also not possible to set records headers.
     *
     * @param timestamp when the operation is being called, depending on {@link PunctuationType}
     */
    void punctuate(long timestamp);
}

相关信息

kafka 源码目录

相关文章

kafka AbstractProcessor 源码

kafka BatchingStateRestoreCallback 源码

kafka Cancellable 源码

kafka CommitCallback 源码

kafka ConnectedStoreProvider 源码

kafka ExtractRecordMetadataTimestamp 源码

kafka FailOnInvalidTimestamp 源码

kafka LogAndSkipOnInvalidTimestamp 源码

kafka Processor 源码

kafka ProcessorContext 源码

0 赞

所属分类： 大数据
本文标签： 大数据
版权声明： 原创文章如转载，请注明本文链接: https://www.seaxiang.com/blog/d1f840fea2e24054ab42d051f96ebe5b

热门推荐

1、直接访问google.com
2、 - 优质文章
3、 gate.io
4、 harmony 鸿蒙hdc使用指导
5、 harmony 鸿蒙ArkUI组件（ArkTS）开发常见问题
6、 harmony 鸿蒙初识ArkTS语言
7、 golang
8、 flink kafka connector scan.startup.mode 的几个选项
9、 openharmony
10、 Vue中input框自动聚焦

Loading...