mumrah / kafka-python / 504

Builds Branch Commit Type Ran Committer Via Coverage
504 master Added basic tests for load_initial_offsets option Pull #354 vshlapakov travis-ci pending completion   set done
503 master Manageable queue.put() operation for MPConsumer processes Pull #336 vshlapakov travis-ci pending completion   set done
502 master Manageable queue.put() operation for MPConsumer processes Pull #336 vshlapakov travis-ci pending completion   set done
501 master Fixed tests and other issues after rebase Pull #331 vshlapakov travis-ci pending completion   set done
500 master Added pylint.rc: ignoring SyncManager for pylint Pull #336 vshlapakov travis-ci pending completion   set done
499 master Using mp.manager to solve the issue with join for MPConsumer Pull #336 vshlapakov travis-ci pending completion   set done
498 master Moving to **kwargs for MPConsumer options Pull #336 vshlapakov travis-ci pending completion   set done
497 master Deprecate KafkaConsumer config metadata_broker_list in favor of bootstrap_servers Pull #340 dpkp travis-ci pending completion   set done
496 master Allow MP Consumers to request offset in child consumers If auto_commit is set on the mp consumers or an explicit start_from_beginning is set to False, the child workers will request the last known offsets as well. Pull #352 alisaifee travis-ci pending completion   set done
495 master Merge branch 'master' of https://github.com/mumrah/kafka-python Pull #351 redsand travis-ci pending completion   set done
494 master Increase count_since_commit on seek When auto_commit is False this change enables an explicit call to commit() to actually commit the offsets. Otherwise a consumer won't be able to commit until at least one message is read. Pull #350 ecanzonieri travis-ci pending completion   set done
493 master Using iter_timeout=0 for MP inner consumer in tests Pull #336 vshlapakov travis-ci pending completion   set done
492 master Merge pull request #335 from scrapinghub/fix-mp-consumer-distribution Wrong partitions distribution logic for MP Consumer push dpkp travis-ci pending completion   set done
491 master Used thread-safe dict.copy().keys() for MP consumer partitions Pull #335 vshlapakov travis-ci pending completion   set done
490 master change correlation_id to be unsigned and only allow uint32 numbers to be assigned to it. addresses #344 Pull #345 richchang0 travis-ci pending completion   set done