Commits

Breadcrumbs

History for

onmaster

User selector

All users

All time

Commit History

Commits on Jan 5, 2019

• Use Popen.communicate() instead of Popen.wait()

  Show description for d2f9413
  

  Baisang

  authored and

  jeffwidman

  committed
  d2f9413

  Copy full SHA for d2f9413

Commits on Nov 20, 2018

• Cleanup formatting, no functional changes

  Show description for 7444e07
  jeffwidman

  committed
  7444e07

  Copy full SHA for 7444e07

Commits on Nov 18, 2018

• Be explicit with tuples for %s formatting

  Show description for 1d44363
  jeffwidman

  committed
  1d44363

  Copy full SHA for 1d44363

Commits on Nov 10, 2018

• Migrate from `Unittest` to `pytest` (#1620)

  

  jeffwidman

  authored and

  dpkp

  committed
  bb5bc1f

  Copy full SHA for bb5bc1f

Commits on Oct 27, 2018

• Cleanup fixture imports

  Show description for f00016e
  jeffwidman

  committed
  f00016e

  Copy full SHA for f00016e

• Minor aesthetic cleanup of partitioner tests

  jeffwidman

  committed
  1945ad1

  Copy full SHA for 1945ad1

• Remove unused ivy_root variable

  Show description for 2b67493
  jeffwidman

  committed
  2b67493

  Copy full SHA for 2b67493

Commits on Oct 25, 2018

• Add KafkaAdmin class

  Show description for 481f880
  

  llamahunter

  authored and

  jeffwidman

  committed
  481f880

  Copy full SHA for 481f880

Commits on Oct 22, 2018

• Vendor `six` consistently

  Show description for b83feec
  jeffwidman

  committed
  b83feec

  Copy full SHA for b83feec

• Fix typo in file name

  jeffwidman

  committed
  0c3f2c1

  Copy full SHA for 0c3f2c1

Commits on Sep 27, 2018

• Support produce with Kafka record headers

  

  hnousiainen

  authored and

  jeffwidman

  committed
  08c7749

  Copy full SHA for 08c7749

• Expose record headers in ConsumerRecords

  

  hnousiainen

  authored and

  jeffwidman

  committed
  0ca4313

  Copy full SHA for 0ca4313

• Add positive tests for headers in record encode/decode

  

  hnousiainen

  authored and

  jeffwidman

  committed
  9d30ab8

  Copy full SHA for 9d30ab8

Commits on Jun 5, 2018

• Don't use `kafka.common` internally

  Show description for bc4cc43
  jeffwidman

  committed
  bc4cc43

  Copy full SHA for bc4cc43

Commits on May 26, 2018

• Ignore MetadataResponses with empty broker list (#1506)

  dpkp

  authored
  ee26c3f

  Copy full SHA for ee26c3f

Commits on May 23, 2018

• Stop shadowing `ConnectionError`

  Show description for 11cf397
  jeffwidman

  committed
  11cf397

  Copy full SHA for 11cf397

Commits on Apr 18, 2018

• Skip flakey SimpleProducer test

  dpkp

  committed
  b6ffbaa

  Copy full SHA for b6ffbaa

• Add codec validators to record parser and builder for all formats (#1447)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  908ac8f

  Copy full SHA for 908ac8f

• Fix MemoryRecord bugs re error handling and add test coverage (#1448)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  d9e41c8

  Copy full SHA for d9e41c8

Commits on Mar 23, 2018

• Change SimpleProducer to use async_send (async is reserved in py37) (#1454)

  dpkp

  authored
  b62006a

  Copy full SHA for b62006a

• Fix skipped integration tests if KAFKA_VERSION unset (#1453)

  dpkp

  authored
  e8cb888

  Copy full SHA for e8cb888

Commits on Mar 10, 2018

• Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)

  dpkp

  authored
  acbc346

  Copy full SHA for acbc346

Commits on Mar 9, 2018

• Add BrokerConnection.connect_blocking() (#1411)

  dpkp

  authored
  1ffdd5c

  Copy full SHA for 1ffdd5c

• Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes for current lookups (#1422)

  dpkp

  authored
  ce96752

  Copy full SHA for ce96752

Commits on Mar 8, 2018

• Fix BrokerConnection.connection_delay() to return milliseconds (#1414)

  dpkp

  authored
  b33a651

  Copy full SHA for b33a651

• Close KafkaConsumer instances during tests (#1410)

  dpkp

  authored
  4c383da

  Copy full SHA for 4c383da

Commits on Feb 26, 2018

• Fix KafkaConsumer compacted offset handling (#1397)

  dpkp

  authored
  4cadaaf

  Copy full SHA for 4cadaaf

Commits on Feb 21, 2018

• Fixes racing condition when message is sent to broker before topic logs are created

  

  asdaraujo

  authored and

  jeffwidman

  committed
  fb279d7

  Copy full SHA for fb279d7

• Introduce new fixtures to prepare for migration to pytest.

  Show description for a1869c4
  

  asdaraujo

  authored and

  jeffwidman

  committed
  a1869c4

  Copy full SHA for a1869c4

• Use hardware accelerated CRC32C function if available (#1389)

  Show description for 0c0c7ea
  tvoinarovskyi

  authored
  0c0c7ea

  Copy full SHA for 0c0c7ea

Commits on Feb 9, 2018

• Increase some integration test timeouts (#1374)

  dpkp

  authored
  8655c75

  Copy full SHA for 8655c75

Commits on Feb 6, 2018

• Avoid consuming duplicate compressed messages from mid-batch (#1367)

  dpkp

  authored
  441aeb8

  Copy full SHA for 441aeb8

Commits on Feb 3, 2018

• KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)

  dpkp

  authored
  618c505

  Copy full SHA for 618c505

Commits on Jan 26, 2018

• Use 0.11.0.2 kafka broker for integration testing (#1357)

  dpkp

  authored
  3e12607

  Copy full SHA for 3e12607

Commits on Jan 12, 2018

• Minor test cleanups (#1343)

  dpkp

  authored
  34fea65

  Copy full SHA for 34fea65