Package io.confluent.telemetry.events.exporter.kafka
package io.confluent.telemetry.events.exporter.kafka
-
ClassesClassDescriptionAn event filter that filters based on the route extension.A partitioner that reduces the number of connections a producer needs to make by Specifying a subset percentage of total partitions to produce to Randomly connecting to brokers and taking all partitions on that broker until it has connected to the subset of partitions Randomly produce to the recorded partitions NOTE: This partitioner will not respect keys when determining the partition to be used. This is done so that keyed messages do not result in connections to every broker.