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, Integer lingerMs, Integer batchSize, Integer bufferMemory, String compressionType, Integer connectionsMaxIdleMs, Integer deliveryTimeoutMs, Boolean enableIdempotence, String interceptorClasses, Integer maxBlockMs, Integer maxInFlightRequestsPerConnection, Integer maxRequestSize, Integer metadataMaxAgeMs, Integer requestTimeoutMs, Integer retries, Integer retryBackoffMs, Integer transactionTimeoutMs, String transactionalId, String clientId, String keySerializer, String valueSerializer) extends Record
Boxed: an unset value stays null so safePut omits the property and Kafka applies its own default.

  • Constructor Details

    • KafkaEmitterConfig

      public KafkaEmitterConfig(String topic, String bootstrapServers, String acks, Integer lingerMs, Integer batchSize, Integer bufferMemory, String compressionType, Integer connectionsMaxIdleMs, Integer deliveryTimeoutMs, Boolean enableIdempotence, String interceptorClasses, Integer maxBlockMs, Integer maxInFlightRequestsPerConnection, Integer maxRequestSize, Integer metadataMaxAgeMs, Integer requestTimeoutMs, Integer retries, Integer retryBackoffMs, Integer 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. All components in this record class are compared with Objects::equals(Object,Object).
      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 Integer lingerMs()
      Returns the value of the lingerMs record component.
      Returns:
      the value of the lingerMs record component

    • batchSize

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

    • bufferMemory

      public Integer 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 Integer connectionsMaxIdleMs()
      Returns the value of the connectionsMaxIdleMs record component.
      Returns:
      the value of the connectionsMaxIdleMs record component

    • deliveryTimeoutMs

      public Integer 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 Integer maxBlockMs()
      Returns the value of the maxBlockMs record component.
      Returns:
      the value of the maxBlockMs record component

    • maxInFlightRequestsPerConnection

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

    • maxRequestSize

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

    • metadataMaxAgeMs

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

    • requestTimeoutMs

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

    • retries

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

    • retryBackoffMs

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

    • transactionTimeoutMs

      public Integer 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