Commits

Branch selector

 lz4

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 25, 2016

• Add lz4 to tox environment deps

  

  Dana Powers

  committed
  c118991

  Copy full SHA for c118991

• Convert codec tests to pytest; add simple lz4 test

  

  Dana Powers

  committed
  86639e7

  Copy full SHA for 86639e7

• Add support for LZ4 compressed messages using python-lz4 module

  

  Dana Powers

  committed
  0d58990

  Copy full SHA for 0d58990

• Merge pull request #516 from dpkp/group_id_none

  Show description for 2c7b745
  dpkp

  committed
  2c7b745

  Copy full SHA for 2c7b745

• Disable auto-commit / group assignment in producer test

  

  Dana Powers

  committed
  c02b271

  Copy full SHA for c02b271

• Disable offset commits and auto-partition-assignment when group_id is None

  

  Dana Powers

  committed
  2a19701

  Copy full SHA for 2a19701

• Merge pull request #515 from dpkp/kafka_producer

  Show description for 077dc47
  dpkp

  committed
  077dc47

  Copy full SHA for 077dc47

• Add KafkaProducer to autodocs and README

  

  Dana Powers

  committed
  85c0dd2

  Copy full SHA for 85c0dd2

• Add simple KafkaProducer -> KafkaConsumer integration test

  

  Dana Powers

  committed
  f516231

  Copy full SHA for f516231

• add DefaultPartitioner test

  

  Dana Powers

  committed
  4d993bb

  Copy full SHA for 4d993bb

• Move pytest broker/zk fixtures to test.conftest

  

  Dana Powers

  committed
  acd1ae4

  Copy full SHA for acd1ae4

• Rename legacy producer tests

  

  Dana Powers

  committed
  34a18ae

  Copy full SHA for 34a18ae

• Add KafkaProducer to kafka and kafka.producer module imports

  

  Dana Powers

  committed
  0a6af29

  Copy full SHA for 0a6af29

• Implement new KafkaProducer, mimicing java client interface / design

  

  Dana Powers

  committed
  44330f4

  Copy full SHA for 44330f4

• Sender class to manage background IO for KafkaProducer

  

  Dana Powers

  committed
  434d1ab

  Copy full SHA for 434d1ab

• RecordAccumulator and RecordBatch, for use by async batching KafkaProducer

  

  Dana Powers

  committed
  a250fe3

  Copy full SHA for a250fe3

• Add thread-aware futures for use with KafkaProducer

  

  Dana Powers

  committed
  4761e24

  Copy full SHA for 4761e24

• Add MessageSetBuffer and SimpleBufferPool to manage producer messages

  

  Dana Powers

  committed
  f944392

  Copy full SHA for f944392

Commits on Jan 24, 2016

• DefaultPartitioner - implements java client logic

  

  Dana Powers

  committed
  030d133

  Copy full SHA for 030d133

• Support encode and repr on raw BytesIO MessageSets (used in new producer)

  

  Dana Powers

  committed
  da78721

  Copy full SHA for da78721

• Add Message and MessageSet HEADER_SIZE bytes

  

  Dana Powers

  committed
  ee19cbf

  Copy full SHA for ee19cbf

• Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors

  

  Dana Powers

  committed
  48e9682

  Copy full SHA for 48e9682

• Write bytes to wake_fd

  

  Dana Powers

  committed
  6eecabf

  Copy full SHA for 6eecabf

• Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exception

  

  Dana Powers

  committed
  80c3a76

  Copy full SHA for 80c3a76

• Ignore _socketobject errors in pylint -- v1.5.4 started throwing no-member errors on python 2.7

  

  Dana Powers

  committed
  b52f17e

  Copy full SHA for b52f17e

• Pylint ignores to fix weird 2.7 error in new pylint version

  

  Dana Powers

  committed
  0c395bd

  Copy full SHA for 0c395bd

• Fix client poll tests (called with sleep=False)

  

  Dana Powers

  committed
  962d8c0

  Copy full SHA for 962d8c0

Commits on Jan 23, 2016

• Add available_partitions_for_topic() and partitions_for_broker()

  

  Dana Powers

  committed
  318b107

  Copy full SHA for 318b107

• KafkaClient.add_topic() -- for use by async producer

  

  Dana Powers

  committed
  d2012e0

  Copy full SHA for d2012e0

• Optionally sleep in KafkaClient.poll(), add KafkaClient.wakeup()

  

  Dana Powers

  committed
  b8c2097

  Copy full SHA for b8c2097

Commits on Jan 19, 2016

• Add back connection_delay method to KafkaClient - used by KafkaProducer

  Show description for 4c2ad12
  

  Dana Powers

  committed
  4c2ad12

  Copy full SHA for 4c2ad12

Commits on Jan 13, 2016

• Merge pull request #507 from dpkp/deprecation_warnings

  Show description for 1f6be11
  dpkp

  committed
  1f6be11

  Copy full SHA for 1f6be11

• Merge pull request #503 from dpkp/iterator_fetches

  Show description for 22f84bf
  dpkp

  committed
  22f84bf

  Copy full SHA for 22f84bf

• Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

  

  Dana Powers

  committed
  4079a58

  Copy full SHA for 4079a58

Commits on Jan 12, 2016

• Sleep in KafkaConsumer iterator if no partition assignment; dont block in poll if no in-flight fetches

  

  Dana Powers

  committed
  3e62206

  Copy full SHA for 3e62206

Pagination

Previous

Next