Class ProducerProperties

java.lang.Object
org.springframework.cloud.stream.binder.ProducerProperties
Direct Known Subclasses:
ExtendedProducerProperties
public class ProducerProperties extends Object
Common producer properties.
Author:
Marius Bogoevici, Ilayaperumal Gopinathan, Gary Russell, Oleg Zhurakousky

  • Constructor Details

    • ProducerProperties

      public ProducerProperties()

  • Method Details

    • getBindingName

      public String getBindingName()

    • populateBindingName

      public void populateBindingName(String bindingName)
      This method is not intended as a configuration property to set by the applications. Therefore, we are not providing a proper setter method for this.
      Parameters:
      bindingName - binding name populated by the framework.

    • getPartitionKeyExpression

      public org.springframework.expression.Expression getPartitionKeyExpression()

    • setPartitionKeyExpression

      public void setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression)

    • isPartitioned

      public boolean isPartitioned()

    • getPartitionSelectorExpression

      public org.springframework.expression.Expression getPartitionSelectorExpression()

    • setPartitionSelectorExpression

      public void setPartitionSelectorExpression(org.springframework.expression.Expression partitionSelectorExpression)

    • getPartitionCount

      public int getPartitionCount()

    • setPartitionCount

      public void setPartitionCount(int partitionCount)

    • getRequiredGroups

      public String[] getRequiredGroups()

    • setRequiredGroups

      public void setRequiredGroups(String... requiredGroups)

    • isValidPartitionKeyProperty

      public boolean isValidPartitionKeyProperty()

    • isValidPartitionSelectorProperty

      public boolean isValidPartitionSelectorProperty()

    • getHeaderMode

      public HeaderMode getHeaderMode()

    • setHeaderMode

      public void setHeaderMode(HeaderMode headerMode)

    • isUseNativeEncoding

      public boolean isUseNativeEncoding()

    • setUseNativeEncoding

      public void setUseNativeEncoding(boolean useNativeEncoding)

    • isErrorChannelEnabled

      public boolean isErrorChannelEnabled()

    • setErrorChannelEnabled

      public void setErrorChannelEnabled(boolean errorChannelEnabled)

    • getPartitionKeyExtractorName

      public String getPartitionKeyExtractorName()

    • setPartitionKeyExtractorName

      public void setPartitionKeyExtractorName(String partitionKeyExtractorName)

    • getPartitionSelectorName

      public String getPartitionSelectorName()

    • setPartitionSelectorName

      public void setPartitionSelectorName(String partitionSelectorName)

    • isAutoStartup

      public boolean isAutoStartup()

    • setAutoStartup

      public void setAutoStartup(boolean autoStartup)

    • getPoller

      public ProducerProperties.PollerProperties getPoller()

    • setPoller

      public void setPoller(ProducerProperties.PollerProperties poller)

    • isDynamicPartitionUpdatesEnabled

      public boolean isDynamicPartitionUpdatesEnabled()
      Returns status of property dynamicPartitionUpdatesEnabled.
      Returns:
      true if dynamic updates should are enabled otherwise false

    • setDynamicPartitionUpdatesEnabled

      public void setDynamicPartitionUpdatesEnabled(boolean enabled)
      A flag which enables/disables partition count updates during runtime. Disabled by default. Depends on binder if supported or not. Currently only supported by kafka binder (see 'Partitioning with the Kafka Binder' documentation for details)
      Parameters:
      enabled - true if dynamic updates should be enabled otherwise false