Packages

  • package root
    Definition Classes
    root
  • package org
    Definition Classes
    root
  • package apache
    Definition Classes
    org
  • package kafka
    Definition Classes
    apache
  • package streams
    Definition Classes
    kafka
  • package scala
    Definition Classes
    streams
  • package kstream
    Definition Classes
    scala
  • object Suppressed

    Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.

    Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.

    This was required for compatibility w/ Scala 2.11 + Java 1.8 because the Scala 2.11 compiler doesn't support the use of static methods inside Java interfaces. We have since dropped Scala 2.11 support.

    Definition Classes
    kstream
    Annotations
    @deprecated
    Deprecated

    (Since version 2.5) Use org.apache.kafka.streams.kstream.Suppressed

  • BufferConfig

object BufferConfig

Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.BufferConfig.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BufferConfig
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. def maxBytes(byteLimit: Long): EagerBufferConfig

    Create a size-constrained buffer in terms of the maximum number of bytes it will use.

    Create a size-constrained buffer in terms of the maximum number of bytes it will use.

    byteLimit

    maximum number of bytes to buffer.

    returns

    size-constrained buffer in terms of the maximum number of bytes it will use.

    See also

    org.apache.kafka.streams.kstream.Suppressed.BufferConfig.maxBytes

  13. def maxRecords(recordLimit: Long): EagerBufferConfig

    Create a size-constrained buffer in terms of the maximum number of keys it will store.

    Create a size-constrained buffer in terms of the maximum number of keys it will store.

    recordLimit

    maximum number of keys to buffer.

    returns

    size-constrained buffer in terms of the maximum number of keys it will store.

    See also

    org.apache.kafka.streams.kstream.Suppressed.BufferConfig.maxRecords

  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. def toString(): String
    Definition Classes
    AnyRef → Any
  19. def unbounded(): StrictBufferConfig

    Create a buffer unconstrained by size (either keys or bytes).

    Create a buffer unconstrained by size (either keys or bytes).

    As a result, the buffer will consume as much memory as it needs, dictated by the time bound.

    If there isn't enough heap available to meet the demand, the application will encounter an OutOfMemoryError and shut down (not guaranteed to be a graceful exit). Also, note that JVM processes under extreme memory pressure may exhibit poor GC behavior.

    This is a convenient option if you doubt that your buffer will be that large, but also don't wish to pick particular constraints, such as in testing.

    This buffer is "strict" in the sense that it will enforce the time bound or crash. It will never emit early.

    returns

    a buffer unconstrained by size (either keys or bytes).

    See also

    org.apache.kafka.streams.kstream.Suppressed.BufferConfig.unbounded

  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped