Commits

Branch selector

 absolute_import

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 3, 2016

• Always absolute_import

  dpkp

  committed
  c693709

  Copy full SHA for c693709

• Rename partition_assignment -> assignment in MemberMetadata for consistency

  dpkp

  committed
  aed1a09

  Copy full SHA for aed1a09

• Clarify api_version=str deprecation warning

  dpkp

  committed
  b87ad1e

  Copy full SHA for b87ad1e

Commits on Aug 2, 2016

• Metadata with_partitions() (#787)

  Show description for 40e2faa
  dpkp

  authored
  40e2faa

  Copy full SHA for 40e2faa

• Merge pull request #785 from dpkp/six

  Show description for 99891ad
  dpkp

  authored
  99891ad

  Copy full SHA for 99891ad

Commits on Aug 1, 2016

• Fix offset fetch when partitions are manually assigned (#786)

  dpkp

  authored
  ec286c9

  Copy full SHA for ec286c9

• Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)

  Show description for 41bed56
  dpkp

  authored
  41bed56

  Copy full SHA for 41bed56

• Vendor six 1.10.0

  dpkp

  committed
  51b3d31

  Copy full SHA for 51b3d31

• Move kafka.socketpair to kafka.vendor.socketpair

  dpkp

  committed
  1d23ddd

  Copy full SHA for 1d23ddd

• Move kafka.selectors34 to kafka.vendor.selectors34

  dpkp

  committed
  4828e49

  Copy full SHA for 4828e49

• Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)

  dpkp

  authored
  4162989

  Copy full SHA for 4162989

Commits on Jul 26, 2016

• Document the ssl_password config option (#780)

  Show description for 64d3607
  

  ssaamm

  authored and

  dpkp

  committed
  64d3607

  Copy full SHA for 64d3607

• Merge pull request #772 from dpkp/more_metrics

  Show description for bdb0559
  dpkp

  authored
  bdb0559

  Copy full SHA for bdb0559

• change pickle_method to use python3 special attributes (#777)

  

  jpaulodit

  authored and

  dpkp

  committed
  0d161f7

  Copy full SHA for 0d161f7

Commits on Jul 21, 2016

• Fix typo in KafkaConsumer documentation (#775)

  

  ssaamm

  authored and

  dpkp

  committed
  0776e5a

  Copy full SHA for 0776e5a

Commits on Jul 18, 2016

• Add KafkaClient metrics

  dpkp

  committed
  a871aa6

  Copy full SHA for a871aa6

• Record produce latency and throttling metrics

  dpkp

  committed
  f8b8904

  Copy full SHA for f8b8904

• Add base coordinator metrics

  dpkp

  committed
  3a7802d

  Copy full SHA for 3a7802d

• Fix ProduceResponse v2 throttle_time_ms

  dpkp

  committed
  436b2b2

  Copy full SHA for 436b2b2

Commits on Jul 17, 2016

• Always encode size with MessageSet (#771)

  dpkp

  authored
  deebefa

  Copy full SHA for deebefa

• Catch select errors while capturing test fixture logs

  dpkp

  committed
  cd9aa73

  Copy full SHA for cd9aa73

• Avoid buffer overread when compressing messageset in KafkaProducer

  dpkp

  committed
  d179a3f

  Copy full SHA for d179a3f

• Expand consumer.fetcher comment re comparing request / response offsets

  dpkp

  committed
  77360a1

  Copy full SHA for 77360a1

• Delete KafkaConnection class (#769)

  dpkp

  authored
  0bda9a4

  Copy full SHA for 0bda9a4

• KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770 / #594)

  dpkp

  authored
  68c8a4a

  Copy full SHA for 68c8a4a

• Explicit format string argument indices for python 2.6 compatibility

  dpkp

  committed
  bcbc0c4

  Copy full SHA for bcbc0c4

• Simplify RecordMetadata; short circuit callbacks (#768)

  Show description for 87648d7
  dpkp

  authored
  87648d7

  Copy full SHA for 87648d7

• KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)

  dpkp

  authored
  ade3160

  Copy full SHA for ade3160

• KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)

  dpkp

  authored
  dd50847

  Copy full SHA for dd50847

• KAFKA-2832: Add a consumer config option to exclude internal topics (#765)

  Show description for 31a29ec
  dpkp

  authored
  31a29ec

  Copy full SHA for 31a29ec

• Expose selector type as config option (#764)

  dpkp

  authored
  506d023

  Copy full SHA for 506d023

• Protect writes to wakeup socket with threading lock (#763 / #709)

  dpkp

  authored
  43bbdf1

  Copy full SHA for 43bbdf1

• Merge pull request #762 from dpkp/metadata_v1

  Show description for 5ab4d5c
  dpkp

  authored
  5ab4d5c

  Copy full SHA for 5ab4d5c

• Update kafka configuration links -> 0.10.0.0 docs

  dpkp

  committed
  2a7f4db

  Copy full SHA for 2a7f4db

• Merge pull request #754 from dpkp/benchmarks

  Show description for 947625b
  dpkp

  authored
  947625b

  Copy full SHA for 947625b

Pagination

Previous

Next