|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
acks
SampledStat
that maintains a simple average over its samples.batch.size
block.on.buffer.full
bootstrap.servers
buffer.memory
client.id
poll()
for the subscribed list of topics and partitions.
poll()
for the subscribed list of topics and
partitions.
poll()
call.
poll()
call.
compression.type
poll()
call.
ConsumerRecord
per partition for a particular topic.SampledStat
that maintains a simple count of what it has seen.poll()
call.
ConsumerConfig.FETCH_MIN_BYTES_CONFIG
.
ConsumerConfig.SESSION_TIMEOUT_MS
time window.
MockProducer.clear()
NetworkClient
ConsumerRebalanceCallback
implementation
Properties
object as configuration.
Properties
object as configuration and a
ConsumerRebalanceCallback
implementation.
InputStream
that will decompress data using the LZ4 algorithm.
OutputStream
that will compress data using the LZ4 algorithm.
OutputStream
that will compress data using the LZ4 algorithm.
OutputStream
that will compress data using the LZ4 algorithm.
linger.ms
SampledStat
that gives the max over its samples.max.in.flight.requests.per.connection
max.request.size
Stat
that is also Measurable
(i.e.Records
implementation backed by a ByteBuffer.metadata.fetch.timeout.ms
metadata.max.age.ms
metric.reporters
metric.reporters
metrics.num.samples
metrics.num.samples
metrics.sample.window.ms
metrics.sample.window.ms
SampledStat
that gives the min over its samples.Consumer
interface you can use for testing code that uses Kafka.new MockProducer(true)
poll()
poll()
KafkaProducer
InputStream
.
receive.buffer.bytes
reconnect.backoff.ms
record(1.0)
MemoryRecords
instances to be sent to the server.retries
retry.backoff.ms
poll(timeout)
.
send.buffer.bytes
poll(timeout)
is not invoked, the consumer is
marked dead and a rebalance operation is triggered for the group identified by ConsumerConfig.GROUP_ID_CONFIG
.
timeout.ms
OutputStream
.
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |