Package org.apache.camel.builder.endpoint.dsl

Interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder, org.apache.camel.EndpointConsumerResolver
All Known Subinterfaces:
IggyEndpointBuilderFactory.IggyEndpointBuilder
Enclosing interface:
IggyEndpointBuilderFactory
public static interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder extends org.apache.camel.builder.EndpointConsumerBuilder
Builder for endpoint consumers for the Iggy component.

  • Method Details

    • advanced

      default IggyEndpointBuilderFactory.AdvancedIggyEndpointConsumerBuilder advanced()

    • autoCreateStream

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder autoCreateStream(boolean autoCreateStream)
      Whether to automatically create stream if it does not exist. The option is a: boolean type. Default: true Group: common
      Parameters:
      autoCreateStream - the value to set
      Returns:
      the dsl builder

    • autoCreateStream

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder autoCreateStream(String autoCreateStream)
      Whether to automatically create stream if it does not exist. The option will be converted to a boolean type. Default: true Group: common
      Parameters:
      autoCreateStream - the value to set
      Returns:
      the dsl builder

    • autoCreateTopic

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder autoCreateTopic(boolean autoCreateTopic)
      Whether to automatically create topic if it does not exist. The option is a: boolean type. Default: true Group: common
      Parameters:
      autoCreateTopic - the value to set
      Returns:
      the dsl builder

    • autoCreateTopic

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder autoCreateTopic(String autoCreateTopic)
      Whether to automatically create topic if it does not exist. The option will be converted to a boolean type. Default: true Group: common
      Parameters:
      autoCreateTopic - the value to set
      Returns:
      the dsl builder

    • clientTransport

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder clientTransport(String clientTransport)
      Polling strategy. The option is a: java.lang.String type. Default: TCP Group: common
      Parameters:
      clientTransport - the value to set
      Returns:
      the dsl builder

    • compressionAlgorithm

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder compressionAlgorithm(org.apache.iggy.topic.CompressionAlgorithm compressionAlgorithm)
      Compression algorithm for message payload. The option is a: org.apache.iggy.topic.CompressionAlgorithm type. Default: None Group: common
      Parameters:
      compressionAlgorithm - the value to set
      Returns:
      the dsl builder

    • compressionAlgorithm

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder compressionAlgorithm(String compressionAlgorithm)
      Compression algorithm for message payload. The option will be converted to a org.apache.iggy.topic.CompressionAlgorithm type. Default: None Group: common
      Parameters:
      compressionAlgorithm - the value to set
      Returns:
      the dsl builder

    • host

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder host(String host)
      Iggy server hostname or IP address. The option is a: java.lang.String type. Default: localhost Group: common
      Parameters:
      host - the value to set
      Returns:
      the dsl builder

    • maxTopicSize

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder maxTopicSize(Long maxTopicSize)
      Maximum topic size in bytes (0 means unlimited). The option is a: java.lang.Long type. Default: 0 Group: common
      Parameters:
      maxTopicSize - the value to set
      Returns:
      the dsl builder

    • maxTopicSize

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder maxTopicSize(String maxTopicSize)
      Maximum topic size in bytes (0 means unlimited). The option will be converted to a java.lang.Long type. Default: 0 Group: common
      Parameters:
      maxTopicSize - the value to set
      Returns:
      the dsl builder

    • messageExpiry

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder messageExpiry(Long messageExpiry)
      Message expiry time in seconds (0 means no expiry). The option is a: java.lang.Long type. Default: 0 Group: common
      Parameters:
      messageExpiry - the value to set
      Returns:
      the dsl builder

    • messageExpiry

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder messageExpiry(String messageExpiry)
      Message expiry time in seconds (0 means no expiry). The option will be converted to a java.lang.Long type. Default: 0 Group: common
      Parameters:
      messageExpiry - the value to set
      Returns:
      the dsl builder

    • partitionsCount

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder partitionsCount(Long partitionsCount)
      Number of partitions for the topic. The option is a: java.lang.Long type. Default: 1 Group: common
      Parameters:
      partitionsCount - the value to set
      Returns:
      the dsl builder

    • partitionsCount

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder partitionsCount(String partitionsCount)
      Number of partitions for the topic. The option will be converted to a java.lang.Long type. Default: 1 Group: common
      Parameters:
      partitionsCount - the value to set
      Returns:
      the dsl builder

    • password

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder password(String password)
      Iggy password. The option is a: java.lang.String type. Group: common
      Parameters:
      password - the value to set
      Returns:
      the dsl builder

    • port

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder port(int port)
      Iggy server port number. The option is a: int type. Default: 8090 Group: common
      Parameters:
      port - the value to set
      Returns:
      the dsl builder

    • port

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder port(String port)
      Iggy server port number. The option will be converted to a int type. Default: 8090 Group: common
      Parameters:
      port - the value to set
      Returns:
      the dsl builder

    • replicationFactor

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder replicationFactor(Short replicationFactor)
      Replication factor for the topic. The option is a: java.lang.Short type. Group: common
      Parameters:
      replicationFactor - the value to set
      Returns:
      the dsl builder

    • replicationFactor

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder replicationFactor(String replicationFactor)
      Replication factor for the topic. The option will be converted to a java.lang.Short type. Group: common
      Parameters:
      replicationFactor - the value to set
      Returns:
      the dsl builder

    • streamId

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder streamId(Long streamId)
      Stream identifier. The option is a: java.lang.Long type. Group: common
      Parameters:
      streamId - the value to set
      Returns:
      the dsl builder

    • streamId

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder streamId(String streamId)
      Stream identifier. The option will be converted to a java.lang.Long type. Group: common
      Parameters:
      streamId - the value to set
      Returns:
      the dsl builder

    • streamName

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder streamName(String streamName)
      Stream name. The option is a: java.lang.String type. Group: common
      Parameters:
      streamName - the value to set
      Returns:
      the dsl builder

    • autoCommit

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder autoCommit(boolean autoCommit)
      Controls message acknowledgment behavior. When true, messages are automatically marked as processed after consumption. When false, enables manual offset management and allows setting a custom starting offset position. The option is a: boolean type. Default: true Group: consumer
      Parameters:
      autoCommit - the value to set
      Returns:
      the dsl builder

    • autoCommit

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder autoCommit(String autoCommit)
      Controls message acknowledgment behavior. When true, messages are automatically marked as processed after consumption. When false, enables manual offset management and allows setting a custom starting offset position. The option will be converted to a boolean type. Default: true Group: consumer
      Parameters:
      autoCommit - the value to set
      Returns:
      the dsl builder

    • consumerGroupName

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder consumerGroupName(String consumerGroupName)
      The name of the consumer group. The option is a: java.lang.String type. Group: consumer
      Parameters:
      consumerGroupName - the value to set
      Returns:
      the dsl builder

    • consumersCount

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder consumersCount(int consumersCount)
      Camel Iggy consumers count. The option is a: int type. Default: 1 Group: consumer
      Parameters:
      consumersCount - the value to set
      Returns:
      the dsl builder

    • consumersCount

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder consumersCount(String consumersCount)
      Camel Iggy consumers count. The option will be converted to a int type. Default: 1 Group: consumer
      Parameters:
      consumersCount - the value to set
      Returns:
      the dsl builder

    • partitionId

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder partitionId(Long partitionId)
      The consumer partition id. The option is a: java.lang.Long type. Group: consumer
      Parameters:
      partitionId - the value to set
      Returns:
      the dsl builder

    • partitionId

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder partitionId(String partitionId)
      The consumer partition id. The option will be converted to a java.lang.Long type. Group: consumer
      Parameters:
      partitionId - the value to set
      Returns:
      the dsl builder

    • pollBatchSize

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder pollBatchSize(Long pollBatchSize)
      The consumer poll batch size. The option is a: java.lang.Long type. Default: 10 Group: consumer
      Parameters:
      pollBatchSize - the value to set
      Returns:
      the dsl builder

    • pollBatchSize

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder pollBatchSize(String pollBatchSize)
      The consumer poll batch size. The option will be converted to a java.lang.Long type. Default: 10 Group: consumer
      Parameters:
      pollBatchSize - the value to set
      Returns:
      the dsl builder

    • pollingStrategy

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder pollingStrategy(String pollingStrategy)
      Polling strategy. The option is a: java.lang.String type. Default: next Group: consumer
      Parameters:
      pollingStrategy - the value to set
      Returns:
      the dsl builder

    • shutdownTimeout

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder shutdownTimeout(int shutdownTimeout)
      Camel Iggy shutdown timeout. The option is a: int type. Default: 30000 Group: consumer
      Parameters:
      shutdownTimeout - the value to set
      Returns:
      the dsl builder

    • shutdownTimeout

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder shutdownTimeout(String shutdownTimeout)
      Camel Iggy shutdown timeout. The option will be converted to a int type. Default: 30000 Group: consumer
      Parameters:
      shutdownTimeout - the value to set
      Returns:
      the dsl builder

    • startingOffset

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder startingOffset(Long startingOffset)
      Defines the initial message offset position when autoCommit is disabled. Use 0 to start from the beginning of the stream, or specify a custom offset to resume from a particular point. The option is a: java.lang.Long type. Default: 0 Group: consumer
      Parameters:
      startingOffset - the value to set
      Returns:
      the dsl builder

    • startingOffset

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder startingOffset(String startingOffset)
      Defines the initial message offset position when autoCommit is disabled. Use 0 to start from the beginning of the stream, or specify a custom offset to resume from a particular point. The option will be converted to a java.lang.Long type. Default: 0 Group: consumer
      Parameters:
      startingOffset - the value to set
      Returns:
      the dsl builder

    • username

      default IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder username(String username)
      Iggy username. The option is a: java.lang.String type. Group: security
      Parameters:
      username - the value to set
      Returns:
      the dsl builder