Commits

Breadcrumbs

History for

onabsolute_import

User selector

All users

All time

Commit History

Commits on Aug 3, 2016

• Always absolute_import

  dpkp

  committed
  c693709

  Copy full SHA for c693709

Commits on Aug 1, 2016

• Move kafka.selectors34 to kafka.vendor.selectors34

  dpkp

  committed
  4828e49

  Copy full SHA for 4828e49

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

• Delete KafkaConnection class (#769)

  dpkp

  authored
  0bda9a4

  Copy full SHA for 0bda9a4

• 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

• Merge pull request #762 from dpkp/metadata_v1

  Show description for 5ab4d5c
  dpkp

  authored
  5ab4d5c

  Copy full SHA for 5ab4d5c

Commits on Jul 16, 2016

• Add initial producer-sender metrics

  dpkp

  committed
  c34d138

  Copy full SHA for c34d138

• Add rack to BrokerMetadata - it is always None when using MetadataRequest v0

  dpkp

  committed
  9960f3d

  Copy full SHA for 9960f3d

• Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)

  dpkp

  authored
  20f4c95

  Copy full SHA for 20f4c95

• Include zk-offset configuration in coordinator unit tests

  dpkp

  committed
  061cb4e

  Copy full SHA for 061cb4e

• Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)

  Show description for a7000ba
  dpkp

  authored
  a7000ba

  Copy full SHA for a7000ba

Commits on Jul 15, 2016

• Test MessageSetBuffer close -- cover double close compression bug

  dpkp

  committed
  594f707

  Copy full SHA for 594f707

Commits on Jun 21, 2016

• Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)

  dpkp

  authored
  cbcb4a6

  Copy full SHA for cbcb4a6

Commits on Jun 18, 2016

• Use weakref when registering a producer.close atexit to fix normal gc (#728)

  Show description for 6271c02
  dpkp

  authored
  6271c02

  Copy full SHA for 6271c02

Commits on Jun 4, 2016

• Rearrange connection tests to separate legacy KafkaConnection

  dpkp

  committed
  81860ee

  Copy full SHA for 81860ee

Commits on Jun 1, 2016

• Fix regression in MessageSet decoding wrt PartialMessages (#716)

  dpkp

  committed
  8805d30

  Copy full SHA for 8805d30

Commits on May 23, 2016

• Fix socket leaks in KafkaClient (#696)

  Show description for 77cb350
  dpkp

  committed
  77cb350

  Copy full SHA for 77cb350

• Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)

  Show description for 1d4251a
  dpkp

  committed
  1d4251a

  Copy full SHA for 1d4251a

Commits on May 22, 2016

• Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)

  dpkp

  committed
  96530f6

  Copy full SHA for 96530f6

• Add some simple message protocol tests

  dpkp

  committed
  aa5bde6

  Copy full SHA for aa5bde6

• Rename legacy protocol tests

  dpkp

  committed
  54eb264

  Copy full SHA for 54eb264

• Improve consumer group test loop

  dpkp

  committed
  7719946

  Copy full SHA for 7719946

Commits on May 10, 2016

• * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages

  Show description for 2c9930d
  

  paulcavallaro

  authored and

  dpkp

  committed
  2c9930d

  Copy full SHA for 2c9930d

Commits on Apr 26, 2016

• Add disconnected socket tests for conn.recv()

  dpkp

  committed
  0b664ff

  Copy full SHA for 0b664ff

• Rename mocked socket as _socket in test_conn

  dpkp

  committed
  2d75945

  Copy full SHA for 2d75945

Commits on Apr 25, 2016

• Merge pull request #670 from zackdever/predictable-future

  Show description for 22dd002
  dpkp

  committed
  22dd002

  Copy full SHA for 22dd002

• Allow setting host interface in KafkaFixture.instance

  dpkp

  committed
  c7564d2

  Copy full SHA for c7564d2

• enable errors on callbacks in testing. fix broken test.

  zackdever

  committed
  87e71b4

  Copy full SHA for 87e71b4

Commits on Apr 24, 2016

• More thorough IPv6 support that uses getaddrinfo to resolve names

  Show description for 434802d
  

  Roguelazer

  authored and

  dpkp

  committed
  434802d

  Copy full SHA for 434802d

Commits on Apr 14, 2016

• instrument metrics for fetch requests

  zackdever

  committed
  e2b340c

  Copy full SHA for e2b340c

• Beginnings of metrics instrumentation in kafka consumer.

  Show description for e010669
  zackdever

  committed
  e010669

  Copy full SHA for e010669

• Basic dictionary reporter in place of the java JMX reporter.

  zackdever

  committed
  caf4cde

  Copy full SHA for caf4cde

• Kafka metrics java port. No reporters or instrumentation.

  Show description for 64e9ceb
  zackdever

  committed
  64e9ceb

  Copy full SHA for 64e9ceb