Class CreateCursorDetails.Builder

    • Constructor Detail

      • Builder

        public Builder()
    • Method Detail

      • partition

        public CreateCursorDetails.Builder partition​(String partition)
        The partition to get messages from.
        Parameters:
        partition - the value to set
        Returns:
        this builder
      • type

        public CreateCursorDetails.Builder type​(CreateCursorDetails.Type type)
        The type of cursor, which determines the starting point from which the stream will be consumed:

        - AFTER_OFFSET: The partition position immediately following the offset you specify. (Offsets are assigned when you successfully append a message to a partition in a stream.) - AT_OFFSET: The exact partition position indicated by the offset you specify. - AT_TIME: A specific point in time. - LATEST: The most recent message in the partition that was added after the cursor was created. - TRIM_HORIZON: The oldest message in the partition that is within the retention period window.

        Parameters:
        type - the value to set
        Returns:
        this builder
      • offset

        public CreateCursorDetails.Builder offset​(Long offset)
        The offset to consume from if the cursor type is AT_OFFSET or AFTER_OFFSET.
        Parameters:
        offset - the value to set
        Returns:
        this builder
      • time

        public CreateCursorDetails.Builder time​(Date time)
        The time to consume from if the cursor type is AT_TIME, expressed in RFC 3339 timestamp format.
        Parameters:
        time - the value to set
        Returns:
        this builder