Druid 加载 Kafka 流数据的性能配置参数 TuningConfig

tuningConfig 的配置是可选的，若是你不在这里对这个参数进行配置的话，Druid 将会使用默认的配置来替代。

字段（Field）	类型（Type）	描述（Description）	是否必须（Required）
type	String	索引任务类型， 老是 kafka。	Y
maxRowsInMemory	Integer	在持久化以前在内存中聚合的最大行数。该数值为聚合以后的行数，因此它不等于原始输入事件的行数，而是事件被聚合后的行数。 一般用来管理所需的 JVM 堆内存。 使用 maxRowsInMemory * (2 + maxPendingPersists) 来当作索引任务的最大堆内存。一般用户不须要设置这个值，可是也须要根据数据的特色来决定，若是行的字节数较短，用户可能不想在内存中存储一百万行，应该设置这个值。	N（默认=1000000）
maxBytesInMemory	Long	在持久化以前在内存中聚合的最大字节数。这是基于对内存使用量的粗略估计，而不是实际使用量。一般这是在内部计算的，用户不须要设置它。 索引任务的最大内存使用量是 maxRowsInMemory * (2 + maxPendingPersists)	N（默认=最大JVM内存的 1/6）
maxRowsPerSegment	Integer	聚合到一个段中的行数，该数值为聚合后的数值。 当 maxRowsPerSegment 或者 maxTotalRows 有一个值命中的时候，则触发 handoff（数据存盘后传到深度存储）， 该动做也会按照每 intermediateHandoffPeriod 时间间隔发生一次。	N（默认=5000000）
maxTotalRows	Long	全部段的聚合后的行数，该值为聚合后的行数。当 maxRowsPerSegment 或者 maxTotalRows 有一个值命中的时候，则触发handoff（数据落盘后传到深度存储）， 该动做也会按照每 intermediateHandoffPeriod 时间间隔发生一次。	N（默认=unlimited)
intermediatePersistPeriod	ISO8601 Period	肯定触发持续化存储的周期	N（默认= PT10M）
maxPendingPersists	Integer	正在等待但启动的持久化过程的最大数量。 若是新的持久化任务超过了此限制，则在当前运行的持久化完成以前，摄取将被阻止。索引任务的最大内存使用量是 maxRowsInMemory * (2 + maxPendingPersists)	否（默认为0，意味着一个持久化能够与摄取同时运行，而没有一个能够进入队列）
indexSpec	Object	调整数据被如何索引。详情能够见 IndexSpec 页面中的内容	N
indexSpecForIntermediatePersists		定义要在索引时用于中间持久化临时段的段存储格式选项。这可用于禁用中间段上的维度/度量压缩，以减小最终合并所需的内存。可是，在中间段上禁用压缩可能会增长页缓存的使用，而在它们被合并到发布的最终段以前使用它们，有关可能的值。详情能够见 IndexSpec 页面中的内容。	N（默认= 与 indexSpec 相同）
reportParseExceptions	Boolean	已经丢弃（DEPRECATED）。若是为true，则在解析期间遇到的异常即中止摄取；若是为false，则将跳过不可解析的行和字段。将 reportParseExceptions 设置为 true 将覆盖maxParseExceptions 和 maxSavedParseExceptions 的现有配置，将maxParseExceptions 设置为 0 并将 maxSavedParseExceptions 限制为不超过1。	N（默认=false）
handoffConditionTimeout	Long	段切换（持久化）能够等待的毫秒数（超时时间）。 该值要被设置为大于0的数，设置为0意味着将会一直等待不超时。	N（默认=0）
resetOffsetAutomatically	Boolean	控制当Druid须要读取Kafka中不可用的消息时的行为，好比当发生了 OffsetOutOfRangeException 异常时。 若是为false，则异常将抛出，这将致使任务失败并中止接收。若是发生这种状况，则须要手动干预来纠正这种状况；可能使用 重置 Supervisor API 。此模式对于生产很是有用，由于它将使您意识到摄取的问题。若是为true，Druid将根据 useEarliestOffset 属性的值（true 为 earliest ，false 为 latest ）自动重置为Kafka中可用的较早或最新偏移量。请注意，这可能致使数据在您不知情的状况下被丢弃 （若是useEarliestOffset 为 false ）或 重复 （若是 useEarliestOffset 为 true ）。消息将被记录下来，以标识已发生重置，但摄取将继续。这种模式对于非生产环境很是有用，由于它将使Druid尝试自动从问题中恢复，即便这些问题会致使数据被安静删除或重复。该特性与Kafka的 auto.offset.reset 消费者属性很类似	N（默认=false）
workerThreads	Integer	supervisor 用于为工做任务处理 请求/相应（requests/responses）异步操做的线程数。	N（默认=min(10, taskCount)）
chatThreads	Integer	与索引任务的会话线程数。	N（默认=10, taskCount * replicas)）
chatRetries	Integer	在任务没有响应以前，将重试对索引任务的HTTP请求的次数	N（默认=8）
httpTimeout	ISO8601 Period	索引任务的 HTTP 响应超时的时间。	N（默认=PT10S）
shutdownTimeout	ISO8601 Period	supervisor 尝试无端障的停掉一个任务的超时时间。	N（默认=PT80S）
offsetFetchPeriod	ISO8601 Period	supervisor 查询 Kafka 和索引任务以获取当前偏移和计算滞后的频率。	N（默认=PT30S，min == PT5S）
segmentWriteOutMediumFactory	Object	建立段时要使用的段写入介质。更多信息见下文。	N （默认不指定，使用来源于 druid.peon.defaultSegmentWriteOutMediumFactory.type 的值）
intermediateHandoffPeriod	ISO8601 Period	段发生切换的频率。当 maxRowsPerSegment 或者 maxTotalRows 有一个值命中的时候，则触发handoff（数据存盘后传到深度存储）， 该动做也会按照每 intermediateHandoffPeriod 时间间隔发生一次。	N（默认=P2147483647D）
logParseExceptions	Boolean	若是为 true，则在发生解析异常时记录错误消息，其中包含有关发生错误的行的信息。	N（默认=false）
maxParseExceptions	Integer	任务中止接收以前可发生的最大分析异常数。若是设置了 reportParseExceptions ，则该值会被重写。	N（默认=unlimited)
maxSavedParseExceptions	Integer	当出现解析异常时，Druid能够跟踪最新的解析异常。"maxSavedParseExceptions"决定将保存多少个异常实例。这些保存的异常将在 任务完成报告 中的任务完成后可用。若是设置了reportParseExceptions ，则该值会被重写。	N（默认=0)