object BufferConfig
Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.BufferConfig.
- Alphabetic
- By Inheritance
- BufferConfig
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
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
-
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
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
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
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()