markmckeown commented on code in PR #4923: URL: https://github.com/apache/polaris/pull/4923#discussion_r3608299792
########## extensions/events/kafka/src/main/java/org/apache/polaris/extensions/events/kafka/KafkaEventListenerConfiguration.java: ########## @@ -0,0 +1,92 @@ +/* + * 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.polaris.extensions.events.kafka; + +import io.quarkus.runtime.annotations.StaticInitSafe; +import io.smallrye.config.ConfigMapping; +import io.smallrye.config.WithDefault; +import io.smallrye.config.WithName; +import java.util.Map; + +/** + * Configuration for the Kafka Event Listener. + * + * <p>Publishes Polaris events to a Kafka topic. The key for the Kafka record is the UUID of the + * Polaris event. To preserve FIFO behavior in the Kafka stream of the Polaris events a single + * partition should be used. + * + * <p>The value of Kafka record is JSON encoded as a String. It consists of a set of key values. The + * set of keys included depends on the Polaris event type and are listed below, the type of value is + * String unless explicitly declared below. + * + * <ul> + * <li>event_type + * <li>timestamp (milliseconds since the epoch, Integer) + * <li>source (source of table rename if the event is a table rename) + * <li>target (destination of table rename the event is a table rename) Review Comment: Thanks @adnanhemani -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
