Class AssociationConfigParser

java.lang.Object

io.confluent.kafka.odyssey.AssociationConfigParser

public class AssociationConfigParser
extends Object

Parser for Odyssey association configurations

Association configs:

• confluent.key.association - JSON payload for key schema association
• confluent.value.association - JSON payload for value schema association

Method Summary

Modifier and Type	Method	Description
static ParsedAssociations	extractAssociations(org.apache.kafka.common.message.CreateTopicsRequestData.CreatableTopicConfigCollection configs)	Extracts association configurations from topic configs.
static void	filterOdysseyConfigsFromTopics(org.apache.kafka.common.message.CreateTopicsRequestData.CreatableTopicCollection topics)	Filters out Odyssey association configs from CreatableTopicCollection in-place.
static Map<String,String>	filterOutOdysseyConfigs(Map<String,String> configs)	Filters out Odyssey association configs from a config map.
static boolean	hasAssociationConfigs(org.apache.kafka.common.message.CreateTopicsRequestData.CreatableTopicConfigCollection configs)	Checks if the topic configs contain any Odyssey association configs.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

hasAssociationConfigs

public static boolean hasAssociationConfigs(org.apache.kafka.common.message.CreateTopicsRequestData.CreatableTopicConfigCollection configs)

Checks if the topic configs contain any Odyssey association configs.

extractAssociations

public static ParsedAssociations extractAssociations(org.apache.kafka.common.message.CreateTopicsRequestData.CreatableTopicConfigCollection configs)

Extracts association configurations from topic configs.

Parameters:

configs - The topic configuration collection

Returns:

ParsedAssociations with optional key and value configs

Throws:

org.apache.kafka.common.config.ConfigException - if payload parsing fails or required fields are missing

filterOutOdysseyConfigs

public static Map<String,String> filterOutOdysseyConfigs(Map<String,String> configs)

Filters out Odyssey association configs from a config map.

filterOdysseyConfigsFromTopics

public static void filterOdysseyConfigsFromTopics(org.apache.kafka.common.message.CreateTopicsRequestData.CreatableTopicCollection topics)

Filters out Odyssey association configs from CreatableTopicCollection in-place.