<?xml version="1.0"?>
<component name="org.nuxeo.ecm.core.bulk.config.override">

  <require>org.nuxeo.ecm.core.bulk.config</require>

  <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.ecm.core.bulk.BulkServiceProcessor" defaultCodec="avro" defaultConcurrency="1" defaultExternal="true" defaultPartitions="1" name="bulkServiceProcessor" start="false">
      <stream external="false" name="bulk/command"/>
      <stream external="false" name="bulk/status"/>
      <stream external="false" name="bulk/done"/>
      <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="0" name="bulk/scroller"/>
      <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="bulk/status"/>
      <computation concurrency="2" name="bulk/scroller"/>
      <computation concurrency="1" name="bulk/status"/>
    </streamProcessor>

    <streamProcessor class="org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionProcessor" defaultCodec="avro" defaultConcurrency="1" defaultPartitions="1" enabled="true" name="streamIntrospection"/>

  </extension>

</component>
