Class Message.Builder

  • Enclosing class:
    Message

    public abstract static class Message.Builder
    extends Object
    • Constructor Detail

      • Builder

        public Builder()
    • Method Detail

      • setKey

        public abstract Message.Builder setKey​(com.google.protobuf.ByteString key)
        The key for this message. All messages with the same key are routed to the same partition.
      • setData

        public abstract Message.Builder setData​(com.google.protobuf.ByteString data)
        The data payload for this message.
      • setAttributes

        public abstract Message.Builder setAttributes​(com.google.common.collect.ImmutableListMultimap<String,​com.google.protobuf.ByteString> attributes)
        A multimap of attributes for this message.
      • setEventTime

        public abstract Message.Builder setEventTime​(com.google.protobuf.Timestamp eventTime)
        The user provided event time for this message.
      • build

        public abstract Message build()
        Build a message.