Packages

c

io.aiven.guardian.kafka.models

ReducedConsumerRecord

final case class ReducedConsumerRecord(topic: String, partition: Int, offset: Long, key: Option[String], value: String, timestamp: Long, timestampType: TimestampType) extends Product with Serializable

A ConsumerRecord that only contains the necessary data for guardian

topic

The kafka topic (same as ConsumerRecord topic)

offset

The kafka offset (same as ConsumerRecord offset)

key

Base64 encoded version of the original ConsumerRecord key as a byte array

value

Base64 encoded version of the original ConsumerRecord value as a byte array

timestamp

The timestamp value (same as ConsumerRecord timestamp)

timestampType

The timestamp type (same as ConsumerRecord timestampType)

Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReducedConsumerRecord
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ReducedConsumerRecord(topic: String, partition: Int, offset: Long, key: Option[String], value: String, timestamp: Long, timestampType: TimestampType)

    topic

    The kafka topic (same as ConsumerRecord topic)

    offset

    The kafka offset (same as ConsumerRecord offset)

    key

    Base64 encoded version of the original ConsumerRecord key as a byte array

    value

    Base64 encoded version of the original ConsumerRecord value as a byte array

    timestamp

    The timestamp value (same as ConsumerRecord timestamp)

    timestampType

    The timestamp type (same as ConsumerRecord timestampType)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  8. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  9. val key: Option[String]
  10. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  12. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  13. val offset: Long
  14. val partition: Int
  15. def productElementNames: Iterator[String]
    Definition Classes
    Product
  16. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  17. val timestamp: Long
  18. val timestampType: TimestampType
  19. def toOffsetDateTime: OffsetDateTime
  20. val topic: String
  21. val value: String
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped