Class TenantClientQuotaFormatter

java.lang.Object
io.confluent.kafka.multitenant.quota.TenantClientQuotaFormatter
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.MessageFormatter

public class TenantClientQuotaFormatter extends Object implements org.apache.kafka.common.MessageFormatter
  • Constructor Details

    • TenantClientQuotaFormatter

      public TenantClientQuotaFormatter()
  • Method Details

    • writeTo

      public void writeTo(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord, PrintStream output)
      Specified by:
      writeTo in interface org.apache.kafka.common.MessageFormatter