Interface SchemaInfoProvider

    • Method Detail

      • getSchemaByVersion

        java.util.concurrent.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

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

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