diff options
| author | Taras <voyn1991@gmail.com> | 2017-10-12 11:07:14 +0300 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2017-10-12 11:10:44 +0300 |
| commit | d10051bb09942bfd48c6f262a8cdbf5651963c2e (patch) | |
| tree | 1f6a262324e3ced9c8655d71fbed5e9ed8a0234d /benchmarks/record_batch_read.py | |
| parent | e992fbfad926486766ff7b63a499f9cf29984fec (diff) | |
| download | kafka-python-d10051bb09942bfd48c6f262a8cdbf5651963c2e.tar.gz | |
Added minor fixes for PR review
Diffstat (limited to 'benchmarks/record_batch_read.py')
| -rw-r--r-- | benchmarks/record_batch_read.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/benchmarks/record_batch_read.py b/benchmarks/record_batch_read.py index 4ded5b0..7ae471e 100644 --- a/benchmarks/record_batch_read.py +++ b/benchmarks/record_batch_read.py @@ -1,11 +1,13 @@ #!/usr/bin/env python from __future__ import print_function -import perf -from kafka.record.memory_records import MemoryRecords, MemoryRecordsBuilder -import itertools -import random import hashlib +import itertools import os +import random + +import perf + +from kafka.record.memory_records import MemoryRecords, MemoryRecordsBuilder DEFAULT_BATCH_SIZE = 1600 * 1024 |