Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 20, 2024

• KIP-345 Static membership implementation (#137)

  Show description for 3c124b2
  

  3 peopleauthored
  3c124b2

  Copy full SHA for 3c124b2

Commits on Mar 19, 2024

• Remove all vendoring (#169)

  Show description for a856dc4
  s-t-e-v-e-n-k

  authored
  a856dc4

  Copy full SHA for a856dc4

Commits on Mar 18, 2024

• Run pyupgrade on everything. (#171)

  wbarnha

  authored
  fcca556

  Copy full SHA for fcca556

Commits on Dec 2, 2020

• Support configuration of custom kafka client for Admin/Consumer/Producer (#2144)

  

  Tincu Gabriel

  authored
  c48817e

  Copy full SHA for c48817e

Commits on Nov 15, 2020

• KafkaConsumer: Exit poll if consumer is closed (#2152)

  rikonen

  authored
  6c87155

  Copy full SHA for 6c87155

Commits on Mar 2, 2020

• Fix docs by adding SASL mention

  Show description for 34dc36d
  jeffwidman

  authored
  34dc36d

  Copy full SHA for 34dc36d

Commits on Dec 30, 2019

• Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)

  dpkp

  authored
  2a86b23

  Copy full SHA for 2a86b23

• Raise AssertionError if consumer closed in poll() (#1978)

  dpkp

  authored
  23534b4

  Copy full SHA for 23534b4

Commits on Dec 29, 2019

• Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)

  

  swenzel

  authored and

  dpkp

  committed
  ee1c4a4

  Copy full SHA for ee1c4a4

• Improve docs for reconnect_backoff_max_ms (#1976)

  dpkp

  authored
  cf28da8

  Copy full SHA for cf28da8

Commits on Oct 11, 2019

• Remove SimpleClient, Producer, Consumer, Unittest (#1196)

  Show description for 3631bfa
  jeffwidman

  authored
  3631bfa

  Copy full SHA for 3631bfa

Commits on Sep 30, 2019

• Improve/refactor bootstrap_connected

  dpkp

  committed
  87fb1bb

  Copy full SHA for 87fb1bb

• Added a function to determine if bootstrap is successfully connected (#1876)

  

  Wayde2014

  authored and

  dpkp

  committed
  7a7a890

  Copy full SHA for 7a7a890

• Send socket data via non-blocking IO with send buffer (#1912)

  dpkp

  authored
  392d674

  Copy full SHA for 392d674

Commits on Sep 29, 2019

• Wrap consumer.poll() for KafkaConsumer iteration (#1902)

  dpkp

  authored
  5d1d424

  Copy full SHA for 5d1d424

Commits on Aug 16, 2019

• Reduce internal client poll timeout for consumer iterator interface (#1824)

  Show description for 5bc2529
  

  dpkp

  authored and

  jeffwidman

  committed
  5bc2529

  Copy full SHA for 5bc2529

Commits on Jul 11, 2019

• Update link to upstream Kafka docs

  Show description for fb87a35
  jeffwidman

  authored
  fb87a35

  Copy full SHA for fb87a35

Commits on May 24, 2019

• Update docs for api_version_auto_timeout_ms (#1812)

  Show description for cee4d17
  jeffwidman

  committed
  cee4d17

  Copy full SHA for cee4d17

Commits on May 23, 2019

• Fix typo in _fetch_all_topic_metadata function (#1809)

  

  Baisang

  authored and

  jeffwidman

  committed
  1a0f297

  Copy full SHA for 1a0f297

• Make partitions_for_topic a read-through cache (#1781)

  Show description for 1f73287
  

  Baisang

  authored and

  jeffwidman

  committed
  1f73287

  Copy full SHA for 1f73287

Commits on May 17, 2019

• Update link to kafka docs

  Show description for 1b6c9c7
  jeffwidman

  authored
  1b6c9c7

  Copy full SHA for 1b6c9c7

Commits on Mar 24, 2019

• Update sasl configuration docstrings

  dpkp

  committed
  ce9c1d2

  Copy full SHA for ce9c1d2

Commits on Mar 23, 2019

• Support SASL OAuthBearer Authentication (#1750)

  

  pt2pham

  authored and

  dpkp

  committed
  8e2ed3e

  Copy full SHA for 8e2ed3e

Commits on Mar 22, 2019

• Allow configuration of SSL Ciphers (#1755)

  

  dpkp

  authored and

  jeffwidman

  committed
  0bc7518

  Copy full SHA for 0bc7518

Commits on Mar 15, 2019

• Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)

  

  jeffwidman

  authored and

  dpkp

  committed
  965d21b

  Copy full SHA for 965d21b

Commits on Mar 8, 2019

• Do network connections and writes in KafkaClient.poll() (#1729)

  Show description for 8c07925
  dpkp

  authored
  8c07925

  Copy full SHA for 8c07925

Commits on Jan 13, 2019

• Remove unused `skip_double_compressed_messages`

  Show description for e54f5a3
  jeffwidman

  committed
  e54f5a3

  Copy full SHA for e54f5a3

Commits on Dec 27, 2018

• #1681 add copy() in metrics() to avoid thread safety issues (#1682)

  

  emeric254

  authored and

  tvoinarovskyi

  committed
  807ac82

  Copy full SHA for 807ac82

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 Aug 31, 2018

• add kerberos domain name config for gssapi sasl mechanism handshake (#1542)

  

  the-sea

  authored and

  dpkp

  committed
  36b53f4

  Copy full SHA for 36b53f4

Commits on Jun 26, 2018

• Document connections_max_idle_ms

  Show description for 9ac3cb1
  jeffwidman

  committed
  9ac3cb1

  Copy full SHA for 9ac3cb1

Commits on Mar 23, 2018

• Fix KafkaConsumer docstring for request_timeout_ms default (#1459)

  dpkp

  authored
  c0fddbd

  Copy full SHA for c0fddbd

Commits on Mar 10, 2018

• Do not validate api_version against known versions (#1434)

  dpkp

  authored
  22e3f75

  Copy full SHA for 22e3f75

Commits on Mar 8, 2018

• Avoid tight poll loop in consumer when brokers are down (#1415)

  dpkp

  authored
  4abdb1b

  Copy full SHA for 4abdb1b

Commits on Feb 27, 2018

• Validate max_records in KafkaConsumer.poll (#1398)

  dpkp

  authored
  793dc4d

  Copy full SHA for 793dc4d

Pagination

Previous

Next