Commits

Branch selector

 streams

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 16, 2018

• Test streams thingy

  dpkp

  committed
  19fc23c

  Copy full SHA for 19fc23c

Commits on Sep 24, 2016

• Fixup kafka streams consumer configs

  dpkp

  committed
  3199394

  Copy full SHA for 3199394

• Fixes to kafka.streams -- simple source -> sink topology works

  dpkp

  committed
  c72b69b

  Copy full SHA for c72b69b

• First scratch commit kafka.streams

  dpkp

  committed
  26fe1f2

  Copy full SHA for 26fe1f2

Commits on Sep 15, 2016

• Fix message timestamp_type (#828)

  

  qix

  authored and

  dpkp

  committed
  2a7aca1

  Copy full SHA for 2a7aca1

• Added ssl_password config option to KafkaProducer class, identical to… (#830)

  Show description for 1646edf
  

  kierkegaard13

  authored and

  dpkp

  committed
  1646edf

  Copy full SHA for 1646edf

Commits on Sep 4, 2016

• from kafka import ConsumerRebalanceListener, OffsetAndMetadata

  dpkp

  committed
  1937ce5

  Copy full SHA for 1937ce5

Commits on Aug 21, 2016

• Fix quota violation exception message (#809)

  dpkp

  authored
  7d31aa3

  Copy full SHA for 7d31aa3

• Improve KafkaProducer docstring re retries config

  dpkp

  committed
  754ff89

  Copy full SHA for 754ff89

Commits on Aug 20, 2016

• Add comment for round robin partitioner with different subscriptions

  dpkp

  committed
  e50d4dd

  Copy full SHA for e50d4dd

Commits on Aug 12, 2016

• Use 0.10.0.1 for integration tests (#803)

  Show description for e5c6487
  dpkp

  authored
  e5c6487

  Copy full SHA for e5c6487

Commits on Aug 11, 2016

• Bump version for development

  dpkp

  committed
  1662c63

  Copy full SHA for 1662c63

Commits on Aug 9, 2016

• Patch Release 1.3.1

  dpkp

  committed
  221fa65

  Copy full SHA for 221fa65

• HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) (#799)

  dpkp

  authored
  a71bee5

  Copy full SHA for a71bee5

Commits on Aug 5, 2016

• Bump version for development

  dpkp

  committed
  6a8f041

  Copy full SHA for 6a8f041

• Release 1.3.0

  dpkp

  committed
  9c44ef3

  Copy full SHA for 9c44ef3

• Dump fixture logs on failure

  dpkp

  committed
  79c9968

  Copy full SHA for 79c9968

• Drain pending requests to the coordinator before initiating group rejoin (#798)

  dpkp

  authored
  f6d2168

  Copy full SHA for f6d2168

• Send combined size and payload bytes to socket to avoid potentially split packets with TCP_NODELAY (#797)

  dpkp

  authored
  d3d3ad8

  Copy full SHA for d3d3ad8

• Merge pull request #796 from dpkp/fixture_auto_ports

  Show description for b24a5c2
  dpkp

  authored
  b24a5c2

  Copy full SHA for b24a5c2

Commits on Aug 4, 2016

• Dont include kafka.vendor in coverage

  dpkp

  committed
  8d19cae

  Copy full SHA for 8d19cae

• Try to bind to a new port on fixture failure retries

  dpkp

  committed
  c061b9b

  Copy full SHA for c061b9b

• Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer group test (#795)

  dpkp

  authored
  bccac7b

  Copy full SHA for bccac7b

• Merge pull request #794 from dpkp/conn_metrics

  Show description for 68c8fa4
  dpkp

  authored
  68c8fa4

  Copy full SHA for 68c8fa4

• Instrument bufferpool-wait-ratio metric in KafkaProducer

  dpkp

  committed
  025b69e

  Copy full SHA for 025b69e

• Instrument metrics in BrokerConnection

  dpkp

  committed
  460f078

  Copy full SHA for 460f078

• Treat metric_group_prefix as config in KafkaConsumer

  dpkp

  committed
  af08b54

  Copy full SHA for af08b54

• Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient

  dpkp

  committed
  a698162

  Copy full SHA for a698162

• Remove unused import from kafka.conn

  dpkp

  committed
  035e8f0

  Copy full SHA for 035e8f0

• Add BrokerConnection docstring with configuration parameters

  dpkp

  committed
  c572e8d

  Copy full SHA for c572e8d

• Add connection-count to KafkaClient metrics

  dpkp

  committed
  3ed27c6

  Copy full SHA for 3ed27c6

• Add connection-creation-rate / connection-close-rate to KafkaClientMetrics

  dpkp

  committed
  a6b9b13

  Copy full SHA for a6b9b13

• Fix misspelling of "password" (#793)

  

  ssaamm

  authored and

  dpkp

  committed
  3c9b1b6

  Copy full SHA for 3c9b1b6

Commits on Aug 3, 2016

• Ignore socket.error when checking for protocol out of sync prior to socket close (#792)

  dpkp

  authored
  0e753e6

  Copy full SHA for 0e753e6

• Support for PLAIN sasl authentication (PR #779)

  Show description for 709ee3b
  dpkp

  committed
  709ee3b

  Copy full SHA for 709ee3b

Pagination

Previous

Next