Consumers Configurations Yaml View

Consumers:
  - Name:
    TimeoutMs:
    Stage:
    Policies:
      - AdvancedLoadBalance:
        Stages:
          - Rate:
            Amount:
            TimeIntervalMs:
            TimeoutMs:
        Count:
          Count:
        IncreasingLoadBalance:
          MaxRate:
          StartRate:
          RateIncrease:
          RateIncreaseIntervalMs:
          TimeIntervalMs:
        LoadBalance:
          Rate:
          TimeIntervalMs:
        Timeout:
          TimeoutMs:
    DataFilter:
      Body:
      MetaData:
      Timestamp:
    Deserialize:
      Deserializer:
      SpecificType:
        TypeFullName:
        AssemblyName:
    ElasticIndices:
      IndexPattern:
      Password:
      Url:
      Username:
      FilterSecondsBeforeRunStartTime:
      MatchQueryString:
      ReadBatchSize:
      ReadFromRunStartTime:
      RequestTimeoutMs:
      ScrollContextExpirationMs:
      TimestampField:
    IbmMqQueue:
      Channel:
      HostName:
      Manager:
      Port:
      QueueName:
    KafkaTopic:
      GroupId:
      Password:
      TopicName:
      Username:
      AutoOffsetReset:
      EnableAutoCommit:
      FetchMinBytes:
      FetchWaitMaxMs:
      HeartbeatIntervalMs:
      MaxPollIntervalMs:
      MessageMaxBytes:
      PartitionAssignmentStrategy:
      SaslMechanism:
      SecurityProtocol:
      SessionTimeOutMs:
      HostNames: []
    MsSqlTable:
      ConnectionString:
      TableName:
      CommandTimeoutSeconds:
      FilterSecondsBeforeRunStartTime:
      InsertionTimeField:
      InsertionTimeTimeZoneOffsetSummerTime:
      ReadFromRunStartTime:
      WhereStatement:
      ColumnsToIgnore: []
    OracleSqlTable:
      ConnectionString:
      TableName:
      CommandTimeoutSeconds:
      FilterSecondsBeforeRunStartTime:
      InsertionTimeField:
      InsertionTimeTimeZoneOffsetSummerTime:
      ReadFromRunStartTime:
      WhereStatement:
      ColumnsToIgnore: []
    PostgreSqlTable:
      ConnectionString:
      TableName:
      CommandTimeoutSeconds:
      FilterSecondsBeforeRunStartTime:
      InsertionTimeField:
      InsertionTimeTimeZoneOffsetSummerTime:
      IsInsertionTimeFieldTimeZoneTz:
      ReadFromRunStartTime:
      WhereStatement:
      ColumnsToIgnore: []
    RabbitMq:
      Host:
      ContinuationTimeoutSeconds:
      CreatedQueueTimeToExpireMs:
      ExchangeName:
      HandshakeContinuationTimeoutSeconds:
      Password:
      Port:
      QueueName:
      RequestedConnectionTimeoutSeconds:
      RoutingKey:
      Username:
      VirtualHost:
    S3Bucket:
      AccessKey:
      SecretKey:
      ServiceURL:
      StorageBucket:
      Delimiter:
      ForcePathStyle:
      MaximumRetryCount:
      Prefix:
      ReadFromRunStartTime:
      SkipEmptyObjects:
    Socket:
      Host:
      Port:
      ProtocolType:
      AddressFamily:
      BufferSize:
      ReceiveTimeoutMs:
      SeperationChar:
      SocketType:
    TrinoSqlTable:
      Catalog:
      ClientTag:
      ConnectionString:
      Hostname:
      Password:
      Schema:
      TableName:
      Username:
      CommandTimeoutSeconds:
      FilterSecondsBeforeRunStartTime:
      InsertionTimeField:
      InsertionTimeTimeZoneOffsetSummerTime:
      ReadFromRunStartTime:
      WhereStatement:
      ColumnsToIgnore: []