Interface SchemaInfoProvider


@Private @Stable public interface SchemaInfoProvider
Schema Provider.
  • Method Details

    • getSchemaByVersion

      CompletableFuture<SchemaInfo> getSchemaByVersion(byte[] schemaVersion)
      Retrieve the schema info of a given schemaVersion.
      Parameters:
      schemaVersion - schema version
      Returns:
      schema info of the provided schemaVersion
    • getLatestSchema

      CompletableFuture<SchemaInfo> getLatestSchema()
      Retrieve the latest schema info.
      Returns:
      the latest schema
    • getTopicName

      String getTopicName()
      Retrieve the topic name.
      Returns:
      the topic name