Package org.apache.tika.pipes.emitter.kafka

Record Class KafkaEmitterConfig

java.lang.Object
java.lang.Record
org.apache.tika.pipes.emitter.kafka.KafkaEmitterConfig
public record KafkaEmitterConfig(String topic, String bootstrapServers, String acks, int lingerMs, int batchSize, int bufferMemory, String compressionType, int connectionsMaxIdleMs, int deliveryTimeoutMs, boolean enableIdempotence, String interceptorClasses, int maxBlockMs, int maxInFlightRequestsPerConnection, int maxRequestSize, int metadataMaxAgeMs, int requestTimeoutMs, int retries, int retryBackoffMs, int transactionTimeoutMs, String transactionalId, String clientId, String keySerializer, String valueSerializer) extends Record

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaEmitterConfig(String topic, String bootstrapServers, String acks, int lingerMs, int batchSize, int bufferMemory, String compressionType, int connectionsMaxIdleMs, int deliveryTimeoutMs, boolean enableIdempotence, String interceptorClasses, int maxBlockMs, int maxInFlightRequestsPerConnection, int maxRequestSize, int metadataMaxAgeMs, int requestTimeoutMs, int retries, int retryBackoffMs, int transactionTimeoutMs, String transactionalId, String clientId, String keySerializer, String valueSerializer)
    Creates an instance of a KafkaEmitterConfig record class.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    acks()
    Returns the value of the acks record component.
    int
    batchSize()
    Returns the value of the batchSize record component.
    String
    bootstrapServers()
    Returns the value of the bootstrapServers record component.
    int
    bufferMemory()
    Returns the value of the bufferMemory record component.
    String
    clientId()
    Returns the value of the clientId record component.
    String
    compressionType()
    Returns the value of the compressionType record component.
    int
    connectionsMaxIdleMs()
    Returns the value of the connectionsMaxIdleMs record component.
    int
    deliveryTimeoutMs()
    Returns the value of the deliveryTimeoutMs record component.
    boolean
    enableIdempotence()
    Returns the value of the enableIdempotence record component.
    final boolean
    equals(Object o)
    Indicates whether some other object is "equal to" this one.
    final int
    hashCode()
    Returns a hash code value for this object.
    String
    interceptorClasses()
    Returns the value of the interceptorClasses record component.
    String
    keySerializer()
    Returns the value of the keySerializer record component.
    int
    lingerMs()
    Returns the value of the lingerMs record component.
    static KafkaEmitterConfig
    load(String json)
     
    int
    maxBlockMs()
    Returns the value of the maxBlockMs record component.
    int
    maxInFlightRequestsPerConnection()
    Returns the value of the maxInFlightRequestsPerConnection record component.
    int
    maxRequestSize()
    Returns the value of the maxRequestSize record component.
    int
    metadataMaxAgeMs()
    Returns the value of the metadataMaxAgeMs record component.
    int
    requestTimeoutMs()
    Returns the value of the requestTimeoutMs record component.
    int
    retries()
    Returns the value of the retries record component.
    int
    retryBackoffMs()
    Returns the value of the retryBackoffMs record component.
    String
    topic()
    Returns the value of the topic record component.
    final String
    toString()
    Returns a string representation of this record class.
    String
    transactionalId()
    Returns the value of the transactionalId record component.
    int
    transactionTimeoutMs()
    Returns the value of the transactionTimeoutMs record component.
    void
    validate()
     
    String
    valueSerializer()
    Returns the value of the valueSerializer record component.

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • KafkaEmitterConfig

      public KafkaEmitterConfig(String topic, String bootstrapServers, String acks, int lingerMs, int batchSize, int bufferMemory, String compressionType, int connectionsMaxIdleMs, int deliveryTimeoutMs, boolean enableIdempotence, String interceptorClasses, int maxBlockMs, int maxInFlightRequestsPerConnection, int maxRequestSize, int metadataMaxAgeMs, int requestTimeoutMs, int retries, int retryBackoffMs, int transactionTimeoutMs, String transactionalId, String clientId, String keySerializer, String valueSerializer)
      Creates an instance of a KafkaEmitterConfig record class.
      Parameters:
      topic - the value for the topic record component
      bootstrapServers - the value for the bootstrapServers record component
      acks - the value for the acks record component
      lingerMs - the value for the lingerMs record component
      batchSize - the value for the batchSize record component
      bufferMemory - the value for the bufferMemory record component
      compressionType - the value for the compressionType record component
      connectionsMaxIdleMs - the value for the connectionsMaxIdleMs record component
      deliveryTimeoutMs - the value for the deliveryTimeoutMs record component
      enableIdempotence - the value for the enableIdempotence record component
      interceptorClasses - the value for the interceptorClasses record component
      maxBlockMs - the value for the maxBlockMs record component
      maxInFlightRequestsPerConnection - the value for the maxInFlightRequestsPerConnection record component
      maxRequestSize - the value for the maxRequestSize record component
      metadataMaxAgeMs - the value for the metadataMaxAgeMs record component
      requestTimeoutMs - the value for the requestTimeoutMs record component
      retries - the value for the retries record component
      retryBackoffMs - the value for the retryBackoffMs record component
      transactionTimeoutMs - the value for the transactionTimeoutMs record component
      transactionalId - the value for the transactionalId record component
      clientId - the value for the clientId record component
      keySerializer - the value for the keySerializer record component
      valueSerializer - the value for the valueSerializer record component

  • Method Details

    • load

      public static KafkaEmitterConfig load(String json) throws TikaConfigException
      Throws:
      TikaConfigException

    • validate

      public void validate() throws TikaConfigException
      Throws:
      TikaConfigException

    • toString

      public final String toString()
      Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.
      Specified by:
      toString in class Record
      Returns:
      a string representation of this object

    • hashCode

      public final int hashCode()
      Returns a hash code value for this object. The value is derived from the hash code of each of the record components.
      Specified by:
      hashCode in class Record
      Returns:
      a hash code value for this object

    • equals

      public final boolean equals(Object o)
      Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared with Objects::equals(Object,Object); primitive components are compared with '=='.
      Specified by:
      equals in class Record
      Parameters:
      o - the object with which to compare
      Returns:
      true if this object is the same as the o argument; false otherwise.

    • topic

      public String topic()
      Returns the value of the topic record component.
      Returns:
      the value of the topic record component

    • bootstrapServers

      public String bootstrapServers()
      Returns the value of the bootstrapServers record component.
      Returns:
      the value of the bootstrapServers record component

    • acks

      public String acks()
      Returns the value of the acks record component.
      Returns:
      the value of the acks record component

    • lingerMs

      public int lingerMs()
      Returns the value of the lingerMs record component.
      Returns:
      the value of the lingerMs record component

    • batchSize

      public int batchSize()
      Returns the value of the batchSize record component.
      Returns:
      the value of the batchSize record component

    • bufferMemory

      public int bufferMemory()
      Returns the value of the bufferMemory record component.
      Returns:
      the value of the bufferMemory record component

    • compressionType

      public String compressionType()
      Returns the value of the compressionType record component.
      Returns:
      the value of the compressionType record component

    • connectionsMaxIdleMs

      public int connectionsMaxIdleMs()
      Returns the value of the connectionsMaxIdleMs record component.
      Returns:
      the value of the connectionsMaxIdleMs record component

    • deliveryTimeoutMs

      public int deliveryTimeoutMs()
      Returns the value of the deliveryTimeoutMs record component.
      Returns:
      the value of the deliveryTimeoutMs record component

    • enableIdempotence

      public boolean enableIdempotence()
      Returns the value of the enableIdempotence record component.
      Returns:
      the value of the enableIdempotence record component

    • interceptorClasses

      public String interceptorClasses()
      Returns the value of the interceptorClasses record component.
      Returns:
      the value of the interceptorClasses record component

    • maxBlockMs

      public int maxBlockMs()
      Returns the value of the maxBlockMs record component.
      Returns:
      the value of the maxBlockMs record component

    • maxInFlightRequestsPerConnection

      public int maxInFlightRequestsPerConnection()
      Returns the value of the maxInFlightRequestsPerConnection record component.
      Returns:
      the value of the maxInFlightRequestsPerConnection record component

    • maxRequestSize

      public int maxRequestSize()
      Returns the value of the maxRequestSize record component.
      Returns:
      the value of the maxRequestSize record component

    • metadataMaxAgeMs

      public int metadataMaxAgeMs()
      Returns the value of the metadataMaxAgeMs record component.
      Returns:
      the value of the metadataMaxAgeMs record component

    • requestTimeoutMs

      public int requestTimeoutMs()
      Returns the value of the requestTimeoutMs record component.
      Returns:
      the value of the requestTimeoutMs record component

    • retries

      public int retries()
      Returns the value of the retries record component.
      Returns:
      the value of the retries record component

    • retryBackoffMs

      public int retryBackoffMs()
      Returns the value of the retryBackoffMs record component.
      Returns:
      the value of the retryBackoffMs record component

    • transactionTimeoutMs

      public int transactionTimeoutMs()
      Returns the value of the transactionTimeoutMs record component.
      Returns:
      the value of the transactionTimeoutMs record component

    • transactionalId

      public String transactionalId()
      Returns the value of the transactionalId record component.
      Returns:
      the value of the transactionalId record component

    • clientId

      public String clientId()
      Returns the value of the clientId record component.
      Returns:
      the value of the clientId record component

    • keySerializer

      public String keySerializer()
      Returns the value of the keySerializer record component.
      Returns:
      the value of the keySerializer record component

    • valueSerializer

      public String valueSerializer()
      Returns the value of the valueSerializer record component.
      Returns:
      the value of the valueSerializer record component