### Fix producer errors - Increase the value of `ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG` to accomadate slower systems. - Increase the value of producer `ProducerConfig.RETRIES_CONFIG` to 3 (from 0). - Prevent producer to send duplicate messages due to retries by setting `ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG` to `true`.
### Fix consumer errors - Increase `ExecConstants.KAFKA_POLL_TIMEOUT` (from 200 ms). ### Stabilize KafkaFilterPushdownTest - Catch the issue with setup early by checking if expected number of records exist before running tests in `KafkaFilterPushdownTest` class. Please refer to [DRILL-6625](https://issues.apache.org/jira/browse/DRILL-6625) for more details about the fix. [ Full content available at: https://github.com/apache/drill/pull/1463 ] This message was relayed via gitbox.apache.org for [email protected]
