Class Partitioning


  • public class Partitioning
    extends Object
    The main Configuration class for the PartitionBroker plugin
    • Field Detail

      • MAPPER

        public static final com.fasterxml.jackson.databind.ObjectMapper MAPPER
      • TO_STRING_MAPPER

        public static final com.fasterxml.jackson.databind.ObjectMapper TO_STRING_MAPPER
      • byClientId

        public HashMap<String,​Target> byClientId
        If a client connects with a clientId which is listed in the map, then he will be immediately reconnected to the partition target immediately.
      • byUserName

        public HashMap<String,​Target> byUserName
        If a client connects with a user priciple which is listed in the map, then he will be immediately reconnected to the partition target immediately.
      • bySourceIp

        public HashMap<String,​Target> bySourceIp
        If a client connects with source ip which is listed in the map, then he will be immediately reconnected to the partition target immediately.
      • byQueue

        public HashMap<String,​Target> byQueue
        Used to map the preferred partitioning of queues across a set of brokers. Once a it is deemed that a connection mostly works with a set of targets configured in this map, the client will be reconnected to the appropriate target.
      • byTopic

        public HashMap<String,​Target> byTopic
        Used to map the preferred partitioning of topics across a set of brokers. Once a it is deemed that a connection mostly works with a set of targets configured in this map, the client will be reconnected to the appropriate target.
    • Constructor Detail

      • Partitioning

        public Partitioning()