Class ConfluentTopicConfig

java.lang.Object
org.apache.kafka.common.config.ConfluentTopicConfig
public class ConfluentTopicConfig extends Object
Keys that can be used to configure a topic for Confluent Platform Kafka. These keys are useful when creating or reconfiguring a topic using the AdminClient.

  • Field Details

  • Constructor Details

    • ConfluentTopicConfig

      public ConfluentTopicConfig()

  • Method Details

    • isConfluentTopicConfig

      public static boolean isConfluentTopicConfig(String configName)
      Whether the given topic config is Confluent-specific: every confluent.-prefixed config plus the unprefixed Confluent-internal ones (currently only TopicConfig.MAX_DECOMPRESSED_MESSAGE_BYTES_CONFIG).

    • isValidViewSql

      public static boolean isValidViewSql(String value, boolean allowEmpty)
      Returns true if value is a valid CONFLUENT_VIEW_SQL_CONFIG expression.

      A value is valid when it is either:

      • null or empty (when allowEmpty is true), or
      • case-insensitive "select" followed by at least one whitespace character (space, tab, newline, etc.) AND references exactly one source topic — no JOIN, exactly one FROM clause (rules out subqueries, UNION/INTERSECT/EXCEPT, CTEs), and no top-level comma in the FROM clause (rules out implicit cross joins like FROM TopicA, TopicB).

    • isValidViewSql

      public static boolean isValidViewSql(String value)

    • isValidComputePool

      public static boolean isValidComputePool(String value)
      Returns true if value is a valid CONFLUENT_COMPUTE_POOL_CONFIG value.

      A value is valid when it is either:

      • null or empty (the "not a view" default), or
      • starts with CONFLUENT_COMPUTE_POOL_PREFIX followed by at least one letter or digit (e.g. lfcp-pool123).