Code

Draft: Aiokafka kip 345#13

Code

Open

Mopsgeschwindigkeit wants to merge 181 commits intosxmastersmaxtec/faust:sxmasterfrom aiokafka_KIP_345smaxtec/faust:aiokafka_KIP_345Copy head branch name to clipboard

+4,298-1,401

Commits

Commits on May 19, 2022

• re-import orjson module for json serialization/deserialization (faust-streaming#294)

  Show description for 7cc93e8
  

  YiuRULE

  and

  patkivikram

  authored
  7cc93e8

  Copy full SHA for 7cc93e8

Commits on May 25, 2022

• Fix readme typos (faust-streaming#308)

  Show description for 26ff8fc
  wbarnha

  authored
  26ff8fc

  Copy full SHA for 26ff8fc

Commits on Jun 2, 2022

• Faust commits the wrong offset in case of a gap in acks faust-streaming#312 (faust-streaming#313)

  Show description for 00adae7
  

  3 peopleauthored
  00adae7

  Copy full SHA for 00adae7

• updating version

  patkivikram

  committed
  921a089

  Copy full SHA for 921a089

Commits on Jun 7, 2022

• Avoid crash in recovery by pessimistically looking up the earliest key (faust-streaming#289)

  Show description for db6a3ae
  

  cbrand

  and

  patkivikram

  authored
  db6a3ae

  Copy full SHA for db6a3ae

Commits on Jul 19, 2022

• Fix flake warning with bound loop var (faust-streaming#326)

  Show description for 1e9d4a5
  wbarnha

  authored
  1e9d4a5

  Copy full SHA for 1e9d4a5

• If changelog topic partitions are only listed in the actives_tps set … (faust-streaming#325)

  Show description for c4f5b18
  

  3 peopleauthored
  c4f5b18

  Copy full SHA for c4f5b18

• fix twisted link in README.md (faust-streaming#309)

  Show description for 49574b2
  

  wbarnha

  and

  patkivikram

  authored
  49574b2

  Copy full SHA for 49574b2

• Fixed filter not acking filtered out messages. (faust-streaming#208)

  Show description for a887571
  

  4 peopleauthored
  a887571

  Copy full SHA for a887571

• Add method to RocksDB for backing up partitions (faust-streaming#304)

  Show description for 0bb2685
  

  wbarnha

  and

  patkivikram

  authored
  0bb2685

  Copy full SHA for 0bb2685

Commits on Aug 3, 2022

• Remove a broken link in Readme.md (faust-streaming#332)

  Show description for 9eb770a
  

  sefadegirmenci

  and

  wbarnha

  authored
  9eb770a

  Copy full SHA for 9eb770a

Commits on Aug 5, 2022

• Correct pypi link, tar filename and path

  

  Allan Frank

  committed
  04bd278

  Copy full SHA for 04bd278

• Merge pull request faust-streaming#334 from afasseco/fix-pypi-link

  Show description for 9ec1858
  wbarnha

  authored
  9ec1858

  Copy full SHA for 9ec1858

Commits on Aug 10, 2022

• Fix recovery of partitions for large volume writes (faust-streaming#335)

  Show description for 5a2ba13
  wbarnha

  authored
  5a2ba13

  Copy full SHA for 5a2ba13

• missing f prefix on f-string (faust-streaming#337)

  Show description for bd1dabb
  

  russellpierce

  and

  wbarnha

  authored
  bd1dabb

  Copy full SHA for bd1dabb

• Allow rocksdb to accept read_only option in order to share tables among workers (faust-streaming#331)

  Show description for 84e444d
  wbarnha

  authored
  84e444d

  Copy full SHA for 84e444d

Commits on Aug 11, 2022

• add dist.yml for uploading builds to pypi (faust-streaming#338)

  Show description for 79d672c
  wbarnha

  authored
  79d672c

  Copy full SHA for 79d672c

• Update version to 0.8.7

  wbarnha

  authored
  681c2c9

  Copy full SHA for 681c2c9

Commits on Aug 12, 2022

• adding intervaltree to manage gaps in topics to prevent OOM (faust-streaming#282)

  Show description for 1e7be3a
  

  patkivikram

  and

  wbarnha

  authored
  1e7be3a

  Copy full SHA for 1e7be3a

• Build wheels for more platforms (faust-streaming#340)

  Show description for c405dbe
  wbarnha

  authored
  c405dbe

  Copy full SHA for c405dbe

• 🐛 Add key_index_table to app tables. (faust-streaming#249)

  Show description for ce53c40
  

  3 peopleauthored
  ce53c40

  Copy full SHA for ce53c40

Commits on Aug 15, 2022

• set version to v0.8.8

  wbarnha

  authored
  0f4ce83

  Copy full SHA for 0f4ce83

Commits on Aug 16, 2022

• Update links in documentation (faust-streaming#341)

  Show description for b0f927d
  wbarnha

  authored
  b0f927d

  Copy full SHA for b0f927d

Commits on Aug 18, 2022

• Address topics.py error in faust-streaming#175 by callling message.message (faust-streaming#342)

  Show description for 76f720a
  wbarnha

  authored
  76f720a

  Copy full SHA for 76f720a

Commits on Aug 29, 2022

• add noqa: B024 to base classes to pass lint check (faust-streaming#344)

  Show description for 7648c6e
  wbarnha

  authored
  7648c6e

  Copy full SHA for 7648c6e

• 📚 Update github link and copyright (faust-streaming#343)

  Show description for 284d400
  

  lsabi

  and

  wbarnha

  authored
  284d400

  Copy full SHA for 284d400

Commits on Aug 31, 2022

• fix running make develop and restore pre-commit tool (faust-streaming#145)

  Show description for 85534ec
  

  taybin

  and

  wbarnha

  authored
  85534ec

  Copy full SHA for 85534ec

Commits on Sep 1, 2022

• Prepare repo for posting docs on gh-pages (faust-streaming#346)

  Show description for d0894e1
  wbarnha

  authored
  d0894e1

  Copy full SHA for d0894e1

• Change version to 0.8.9 in preparaion of next release

  wbarnha

  authored
  6475f8c

  Copy full SHA for 6475f8c

• cleanup docs build process and add various improvements (faust-streaming#347)

  wbarnha

  authored
  34d2694

  Copy full SHA for 34d2694

Commits on Sep 2, 2022

• Add aerospike docs (faust-streaming#348)

  Show description for 3680bbd
  wbarnha

  authored
  3680bbd

  Copy full SHA for 3680bbd

• Added Aerospike to stores (faust-streaming#350)

  Show description for ba000ee
  

  wbarnha

  and

  elioskmil

  authored
  ba000ee

  Copy full SHA for ba000ee

Commits on Sep 4, 2022

• Add improvements to documentation (faust-streaming#351)

  Show description for 2091326
  wbarnha

  authored
  2091326

  Copy full SHA for 2091326

Commits on Sep 12, 2022

• Update badges and settingref.txt (faust-streaming#353)

  Show description for e661f7b
  wbarnha

  authored
  e661f7b

  Copy full SHA for e661f7b

Commits on Sep 13, 2022

• Dependency update: click version lower than 8.2 (faust-streaming#352)

  Show description for 103fb45
  

  3 peopleauthored
  103fb45

  Copy full SHA for 103fb45

Commits on Sep 14, 2022

• update all references of aioeventlet to faust-aioeventlet (faust-streaming#355)

  Show description for f4da1e8
  wbarnha

  authored
  f4da1e8

  Copy full SHA for f4da1e8

• update tags to 0.8.10 in preparation of next release (faust-streaming#361)

  Show description for 3e4ad8f
  wbarnha

  authored
  3e4ad8f

  Copy full SHA for 3e4ad8f

• Update jinja2 requirement from <3.1.0 to <3.2.0 in /requirements (faust-streaming#360)

  Show description for bbfabae
  

  dependabot[bot]

  and

  wbarnha

  authored
  bbfabae

  Copy full SHA for bbfabae

• Bump actions/download-artifact from 2 to 3 (faust-streaming#357)

  Show description for 334fa46
  dependabot[bot]

  authored
  334fa46

  Copy full SHA for 334fa46

• Bump github/codeql-action from 1 to 2 (faust-streaming#356)

  Show description for 8b4ff3f
  dependabot[bot]

  authored
  8b4ff3f

  Copy full SHA for 8b4ff3f

Commits on Sep 16, 2022

• Update and revamp CHANGELOG.md (faust-streaming#362)

  Show description for 6802654
  wbarnha

  authored
  6802654

  Copy full SHA for 6802654

Commits on Sep 21, 2022

• Remove py3.6 support since EOL'ed (faust-streaming#339)

  Show description for c0a4571
  

  wbarnha

  and

  patkivikram

  authored
  c0a4571

  Copy full SHA for c0a4571

Commits on Sep 22, 2022

• Fixed autodiscovery of logs (faust-streaming#368)

  blazing-gig

  authored
  bc3f533

  Copy full SHA for bc3f533

• Remove more references to 3.6 (faust-streaming#369)

  Show description for 06c0b09
  wbarnha

  authored
  06c0b09

  Copy full SHA for 06c0b09

• Remove hardcoded bandit version and add nosecs (faust-streaming#364)

  Show description for ed6ef04
  wbarnha

  authored
  ed6ef04

  Copy full SHA for ed6ef04

• End wheel builds for Windows (faust-streaming#370)

  wbarnha

  authored
  e60fad3

  Copy full SHA for e60fad3

Commits on Sep 28, 2022

• Bump actions/checkout from 2 to 3 (faust-streaming#371)

  Show description for fa5fa81
  dependabot[bot]

  authored
  fa5fa81

  Copy full SHA for fa5fa81

Commits on Oct 3, 2022

• update versioning to 0.8.11 (faust-streaming#374)

  wbarnha

  authored
  c5f28b3

  Copy full SHA for c5f28b3

Commits on Oct 5, 2022

• Adding distributed tracing feature (faust-streaming#376)

  Show description for 347442e
  patkivikram

  authored
  347442e

  Copy full SHA for 347442e

• include agent stopper (faust-streaming#329)

  Show description for a2c77a9
  

  3 peopleauthored
  a2c77a9

  Copy full SHA for a2c77a9

• Change default replication factor for producers (faust-streaming#375)

  Show description for 5790be9
  wbarnha

  authored
  5790be9

  Copy full SHA for 5790be9

• update versioning to 0.9.0 for upcoming release

  wbarnha

  committed
  fda5c40

  Copy full SHA for fda5c40

Commits on Oct 7, 2022

• Update current badge version to 0.8.11

  wbarnha

  authored
  3c50dd1

  Copy full SHA for 3c50dd1

• fix for faust-streaming#378 (faust-streaming#379)

  Show description for 659e2b7
  

  patkivikram

  and

  wbarnha

  authored
  659e2b7

  Copy full SHA for 659e2b7

Commits on Oct 10, 2022

• fix for faust-streaming#378 (faust-streaming#380)

  Show description for ab1c668
  patkivikram

  authored
  ab1c668

  Copy full SHA for ab1c668

• Unmark *some* Aiokafkaconsumer thread tests (faust-streaming#377)

  Show description for 0dab360
  wbarnha

  authored
  0dab360

  Copy full SHA for 0dab360

Commits on Oct 12, 2022

• Update test_open_db_for_partition_max_retries to run again (faust-streaming#383)

  Show description for 51bee49
  wbarnha

  authored
  51bee49

  Copy full SHA for 51bee49

Commits on Oct 13, 2022

• Update version badge to 0.9.0

  wbarnha

  authored
  948dd05

  Copy full SHA for 948dd05

Commits on Oct 24, 2022

• add variable bound agent example (faust-streaming#388)

  Show description for ecee01b
  

  joonjeong

  and

  Dongseob Park

  authored
  ecee01b

  Copy full SHA for ecee01b

• Add take_events() function (faust-streaming#392)

  Show description for 94ff38f
  

  nguyentritai2906

  and

  wbarnha

  authored
  94ff38f

  Copy full SHA for 94ff38f

• Add hopping example (faust-streaming#354)

  Show description for 73e4400
  

  wbarnha

  and

  doncat99

  authored
  73e4400

  Copy full SHA for 73e4400

• start testing table.last_closed_window (faust-streaming#391)

  wbarnha

  authored
  6a1a940

  Copy full SHA for 6a1a940

Commits on Oct 25, 2022

• bump versioning to 0.9.1 in prep of next release (faust-streaming#394)

  Show description for fd088f2
  wbarnha

  authored
  fd088f2

  Copy full SHA for fd088f2

Commits on Oct 28, 2022

• Update github pages only on tagged release (faust-streaming#400)

  wbarnha

  authored
  1ba6962

  Copy full SHA for 1ba6962

• using aiokafka's default partition strategy when table_standy_replicas is 0 (faust-streaming#402)

  Show description for 9aba24c
  

  patkivikram

  and

  wbarnha

  authored
  9aba24c

  Copy full SHA for 9aba24c

Commits on Oct 31, 2022

• bump versions to 0.9.2

  wbarnha

  committed
  52c19a4

  Copy full SHA for 52c19a4

Commits on Nov 1, 2022

• Don't allow consumers to create topics if not allowed (faust-streaming#403)

  Show description for 33340f8
  wbarnha

  authored
  33340f8

  Copy full SHA for 33340f8

Commits on Nov 2, 2022

• Update versions in classifiers

  wbarnha

  authored
  90be0cc

  Copy full SHA for 90be0cc

Commits on Nov 4, 2022

• Use setuptools_scm to automate versioning (faust-streaming#407)

  Show description for 775816c
  wbarnha

  authored
  775816c

  Copy full SHA for 775816c

• Update badges automatically (faust-streaming#404)

  wbarnha

  authored
  c1398b8

  Copy full SHA for c1398b8

• Add more logic to aiokafka driver to prevent topics from being created (faust-streaming#405)

  wbarnha

  authored
  85a649a

  Copy full SHA for 85a649a

• use importlib instead (faust-streaming#408)

  Show description for e2c0a98
  wbarnha

  authored
  e2c0a98

  Copy full SHA for e2c0a98

Commits on Nov 21, 2022

• Update aiokafka requirement in /requirements (faust-streaming#413)

  Show description for 458d6d3
  dependabot[bot]

  authored
  458d6d3

  Copy full SHA for 458d6d3

• version limit mode-streaming while we're working on testing things out (faust-streaming#414)

  wbarnha

  authored
  7bef2a2

  Copy full SHA for 7bef2a2

• Update statsd requirement from ~=3.3.0 to ~=4.0.1 in /requirements (faust-streaming#409)

  Show description for ca2e599
  dependabot[bot]

  authored
  ca2e599

  Copy full SHA for ca2e599

Commits on Nov 29, 2022

• Add support for python3.11 (faust-streaming#366)

  Show description for cf397bc
  wbarnha

  authored
  cf397bc

  Copy full SHA for cf397bc

• Add get_event_loop_policy() to all get_event_loop() calls (faust-streaming#415)

  Show description for 7c7fa84
  wbarnha

  authored
  7c7fa84

  Copy full SHA for 7c7fa84

Commits on Nov 30, 2022

• add 3.11 to setup.py

  wbarnha

  authored
  027808e

  Copy full SHA for 027808e

Commits on Dec 6, 2022

• Fix args for consumer.send in service example

  wbarnha

  authored
  ebc7777

  Copy full SHA for ebc7777

Commits on Dec 14, 2022

• add release back to gh-pages

  wbarnha

  authored
  337cd30

  Copy full SHA for 337cd30

Commits on Dec 15, 2022

• commit various reformatting (faust-streaming#423)

  wbarnha

  authored
  ae685ef

  Copy full SHA for ae685ef

• Assign blessed_key to metadata if blessed_key is defined (faust-streaming#422)

  Show description for e541793
  wbarnha

  authored
  e541793

  Copy full SHA for e541793

Commits on Dec 21, 2022

• Update Slack invite link (faust-streaming#425)

  Show description for df8abb7
  wbarnha

  authored
  df8abb7

  Copy full SHA for df8abb7

Commits on Jan 4, 2023

• Global global tables (faust-streaming#426)

  Show description for a48a7c4
  

  aoberegg

  and

  Alexander Oberegger

  authored
  a48a7c4

  Copy full SHA for a48a7c4

• fix for issue 419 (faust-streaming#420)

  Show description for 89b82ab
  

  patkivikram

  and

  wbarnha

  authored
  89b82ab

  Copy full SHA for 89b82ab

Commits on Jan 10, 2023

• Global global tables (faust-streaming#431)

  Show description for c0fde84
  

  3 peopleauthored
  c0fde84

  Copy full SHA for c0fde84

Commits on Jan 23, 2023

• fix: set missing loop param for service inits (faust-streaming#436)

  

  Daniel Gellert

  authored
  2b8ef5a

  Copy full SHA for 2b8ef5a

Commits on Jan 24, 2023

• faust-streaming#307: Allow custom headers in self.error view method (faust-streaming#437)

  Show description for aaadab2
  

  popadi

  and

  Adrian Pop

  authored
  aaadab2

  Copy full SHA for aaadab2

Commits on Jan 25, 2023

• resolving wrong reference (faust-streaming#438)

  Show description for c20e11c
  

  4 peopleauthored
  c20e11c

  Copy full SHA for c20e11c

Commits on Feb 1, 2023

• fix: set loop for services where missing (faust-streaming#441)

  Show description for 0af3c8a
  dada-engineer

  authored
  0af3c8a

  Copy full SHA for 0af3c8a

• switch pages to deploy when release+created

  wbarnha

  authored
  032294b

  Copy full SHA for 032294b

Commits on Feb 8, 2023

• Fix spelling of NLTK (faust-streaming#445)

  Show description for 87de598
  

  jack-mcivor

  and

  Jack McIvor

  authored
  87de598

  Copy full SHA for 87de598

Commits on Feb 16, 2023

• Update pip installs from faust to faust-streaming

  wbarnha

  authored
  daf1601

  Copy full SHA for daf1601

Commits on Feb 22, 2023

• Update project for flake8 changes (faust-streaming#453)

  Show description for 8fee113
  wbarnha

  authored
  8fee113

  Copy full SHA for 8fee113

• Update pip installs from remaining faust to faust-streaming (faust-streaming#452)

  Show description for 32ea389
  

  gpapia

  and

  wbarnha

  authored
  32ea389

  Copy full SHA for 32ea389

• add OPT_NON_STR_KEYS to orjson (faust-streaming#455)

  Show description for e0b7e3a
  wbarnha

  authored
  e0b7e3a

  Copy full SHA for e0b7e3a

Commits on Feb 23, 2023

• Update Slack invite link

  wbarnha

  authored
  90898ae

  Copy full SHA for 90898ae

• Update Slack link... again.

  wbarnha

  authored
  b9f7a42

  Copy full SHA for b9f7a42

Commits on Feb 24, 2023

• Bump actions/upload-artifact from 2 to 3 (faust-streaming#456)

  Show description for 7ae9009
  dependabot[bot]

  authored
  7ae9009

  Copy full SHA for 7ae9009

Commits on Mar 2, 2023

• Update Slack links

  wbarnha

  committed
  dc8dd31

  Copy full SHA for dc8dd31

Commits on Mar 11, 2023

• Remove pytest-openfiles (faust-streaming#464)

  wbarnha

  authored
  a90a763

  Copy full SHA for a90a763

Commits on Mar 16, 2023

• doc: update testing doc (faust-streaming#467)

  Show description for 50e5066
  thomas-chauvet

  authored
  50e5066

  Copy full SHA for 50e5066

Commits on Mar 17, 2023

• Add support for rocksdict (faust-streaming#470)

  Show description for 9c29611
  wbarnha

  authored
  9c29611

  Copy full SHA for 9c29611

• Allow users to specify RocksDB drivers (faust-streaming#472)

  Show description for d379f4f
  wbarnha

  authored
  d379f4f

  Copy full SHA for d379f4f

• Update README with rocksdict option

  wbarnha

  authored
  5254db2

  Copy full SHA for 5254db2

• Bump rocksdict minimum requirement to 0.3.7 (faust-streaming#475)

  wbarnha

  authored
  3a6ce25

  Copy full SHA for 3a6ce25

Commits on Mar 20, 2023

• Hotfix rocksdict methods (faust-streaming#476)

  Show description for 9fd51e1
  wbarnha

  authored
  9fd51e1

  Copy full SHA for 9fd51e1

• Bump actions/deploy-pages from 1 to 2 (faust-streaming#477)

  Show description for 5c08c27
  dependabot[bot]

  authored
  5c08c27

  Copy full SHA for 5c08c27

Commits on Mar 21, 2023

• Add unit tests for rocksdict to guarantee reliability (faust-streaming#478)

  Show description for d19bd4a
  wbarnha

  authored
  d19bd4a

  Copy full SHA for d19bd4a

Commits on Mar 22, 2023

• use key_may_exist() from rocksdict (faust-streaming#479)

  Show description for 811e032
  wbarnha

  authored
  811e032

  Copy full SHA for 811e032

• Fix test case for test_apply_changelog_batch (faust-streaming#480)

  wbarnha

  authored
  8e75c8e

  Copy full SHA for 8e75c8e

• Hotfix key_may_exist() (faust-streaming#481)

  Show description for 96e54a2
  wbarnha

  authored
  96e54a2

  Copy full SHA for 96e54a2

• pass use_rocksdict kwarg into RocksDBOptions

  wbarnha

  authored
  54dcead

  Copy full SHA for 54dcead

• Lint rocksdb.py

  wbarnha

  committed
  2eda612

  Copy full SHA for 2eda612

Commits on Mar 23, 2023

• Update notes on RocksDB (faust-streaming#483)

  Show description for 93a052e
  wbarnha

  authored
  93a052e

  Copy full SHA for 93a052e

Commits on Mar 24, 2023

• Update note to RocksDB 8 in README

  wbarnha

  authored
  0454fce

  Copy full SHA for 0454fce

• Update note to indicate rocksdict is RocksDB 8

  wbarnha

  authored
  47ce720

  Copy full SHA for 47ce720

Commits on Mar 29, 2023

• create constant exception ERRORS_ROCKS_IO_ERROR in case python-rocksd… (faust-streaming#485)

  Show description for e3f30ac
  wbarnha

  authored
  e3f30ac

  Copy full SHA for e3f30ac

Commits on Mar 30, 2023

• add support for comma separated list of urls (faust-streaming#486)

  ofirt-orca

  authored
  99ab4f6

  Copy full SHA for 99ab4f6

Commits on Apr 3, 2023

• Ack filtered messages when using .take() (faust-streaming#488)

  Show description for f741fd9
  

  artem-ilin

  and

  ArtemIlinArammeem

  authored
  f741fd9

  Copy full SHA for f741fd9

Commits on Apr 7, 2023

• Change requirements to set 3.8.0 as minimum aiohttp version (faust-streaming#490)

  wbarnha

  authored
  d9d2d3e

  Copy full SHA for d9d2d3e

Commits on Apr 9, 2023

• Fix typo in README

  wbarnha

  authored
  ac63372

  Copy full SHA for ac63372

Commits on Apr 10, 2023

• Bump rocksdict to 0.3.11 (faust-streaming#492)

  Show description for ea5d5b5
  

  wbarnha

  and

  patkivikram

  authored
  ea5d5b5

  Copy full SHA for ea5d5b5

Commits on Apr 12, 2023

• Fix CI/CD pipelines due to deleted codecov wheel (faust-streaming#494)

  Show description for 26fc9cd
  wbarnha

  authored
  26fc9cd

  Copy full SHA for 26fc9cd

• align default date format with orjson date format (faust-streaming#493)

  Show description for 277c8b8
  

  ofirt-orca

  and

  wbarnha

  authored
  277c8b8

  Copy full SHA for 277c8b8

Commits on Apr 27, 2023

• Create lint.yml (faust-streaming#499)

  Show description for c691c93
  wbarnha

  authored
  c691c93

  Copy full SHA for c691c93

• rename master to main in lint.yml

  wbarnha

  authored
  b8b8941

  Copy full SHA for b8b8941

• Set git_no_verify: true in lint.yml

  wbarnha

  authored
  deb8963

  Copy full SHA for deb8963

• remove lint.yml because maybe it's not such a good idea

  wbarnha

  authored
  fbba09d

  Copy full SHA for fbba09d

• updating version to 8.0.0 compatible client (faust-streaming#498)

  Show description for 4242e20
  

  patkivikram

  and

  wbarnha

  authored
  4242e20

  Copy full SHA for 4242e20

Commits on May 24, 2023

• Remove extraneous sleep in SetManager.flush (faust-streaming#504)

  Show description for 17f111f
  richardhundt

  authored
  17f111f

  Copy full SHA for 17f111f

Commits on May 25, 2023

• End support for Python 3.7 (faust-streaming#508)

  Show description for 67b55dd
  wbarnha

  authored
  67b55dd

  Copy full SHA for 67b55dd

• Use proper regex suggested by setuptools_scm for detecting version (faust-streaming#509)

  Show description for 9a1cf92
  wbarnha

  authored
  9a1cf92

  Copy full SHA for 9a1cf92

Commits on Jun 14, 2023

• Ensure callback map is rebuilt after reply_to topics are created (faust-streaming#510)

  Show description for 155e40d
  

  richardhundt

  and

  Richard Hundt

  authored
  155e40d

  Copy full SHA for 155e40d

Commits on Jun 22, 2023

• Fix set operations in ChangeloggedSet (faust-streaming#521)

  Show description for 0531715
  

  3 peopleauthored
  0531715

  Copy full SHA for 0531715

Commits on Jun 25, 2023

• Implement OAuthbearer auth mechanism (faust-streaming#525)

  Show description for ada6429
  cbcoutinho

  authored
  ada6429

  Copy full SHA for ada6429

Commits on Jun 26, 2023

• Fix for current_event not in context during periodic flush (faust-streaming#522)

  Show description for f79cc16
  

  3 peopleauthored
  f79cc16

  Copy full SHA for f79cc16

• Update CI/CD workflows, setup config files, and build wheels for Python >= 3.8 (faust-streaming#524)

  Show description for 600d0ae
  wbarnha

  authored
  600d0ae

  Copy full SHA for 600d0ae

Commits on Jun 29, 2023

• Enable PyPy testing (faust-streaming#530)

  Show description for 7eea54a
  wbarnha

  authored
  7eea54a

  Copy full SHA for 7eea54a

Commits on Jun 30, 2023

• Topic: Remove topic with active_partitions from Conductor after (faust-streaming#531)

  Show description for 236516d
  

  ostetsenko

  and

  o.stetsenko

  authored
  236516d

  Copy full SHA for 236516d

Commits on Jul 11, 2023

• Bump actions/upload-pages-artifact from 1 to 2 (faust-streaming#533)

  Show description for ddf27f5
  dependabot[bot]

  authored
  ddf27f5

  Copy full SHA for ddf27f5

Commits on Jul 27, 2023

• Use rocksdict version >= v0.3.11 (faust-streaming#538)

  Show description for 4a23420
  GodTamIt

  authored
  4a23420

  Copy full SHA for 4a23420

Commits on Aug 9, 2023

• Update python-package.yml to test for Python 3.12 (faust-streaming#540)

  wbarnha

  authored
  87a80a9

  Copy full SHA for 87a80a9

Commits on Aug 14, 2023

• fix: ensure aiokafka commit is called with kafka.structs.TopicPartition (faust-streaming#539) (faust-streaming#541)

  dada-engineer

  authored
  b5db8a0

  Copy full SHA for b5db8a0

Commits on Sep 5, 2023

• Bump actions/checkout from 3 to 4 (faust-streaming#546)

  Show description for e900e54
  dependabot[bot]

  authored
  e900e54

  Copy full SHA for e900e54

Commits on Sep 14, 2023

• Bump codecov/codecov-action from 3 to 4 (faust-streaming#547)

  Show description for 648d506
  dependabot[bot]

  authored
  648d506

  Copy full SHA for 648d506

Commits on Sep 29, 2023

• Revert to codecov/codecov-action@v3 in python-package.yml

  wbarnha

  authored
  da90c7c

  Copy full SHA for da90c7c

Commits on Nov 5, 2023

• Add Python ~3.13 for testing in python-package.yml (faust-streaming#561)

  wbarnha

  authored
  3fb3180

  Copy full SHA for 3fb3180

Commits on Nov 6, 2023

• Merge branch 'sxmaster' into merge_upstream-06-11-2023

  

  Moser Marco Julian

  committed
  56337d8

  Copy full SHA for 56337d8

• fixed test

  

  Moser Marco Julian

  committed
  be9c6d2

  Copy full SHA for be9c6d2

Commits on Nov 7, 2023

• Bump venusian from 3.0.0 to 3.1.0 in /requirements (faust-streaming#562)

  Show description for 5e3cecc
  dependabot[bot]

  authored
  5e3cecc

  Copy full SHA for 5e3cecc

Commits on Nov 16, 2023

• Add a TTL for RocksDB store for removing outdated WAL files (faust-streaming#567)

  YiuRULE

  authored
  ccc062f

  Copy full SHA for ccc062f

Commits on Nov 20, 2023

• fix: docs Autodetect for schemas (faust-streaming#563)

  Show description for e31974f
  

  IbrahimBagalwa

  and

  wbarnha

  authored
  e31974f

  Copy full SHA for e31974f

Commits on Nov 21, 2023

• Fix potential NoneType access in aiokafka driver (faust-streaming#569)

  GodTamIt

  authored
  448a7a4

  Copy full SHA for 448a7a4

• Temporarily fix breaking build with setuptools v69 (faust-streaming#571)

  somnam

  authored
  c629e72

  Copy full SHA for c629e72

Commits on Nov 27, 2023

• Fix AccessType assigninment in rocksdb.py (faust-streaming#575)

  Show description for ad8dd0e
  wbarnha

  authored
  ad8dd0e

  Copy full SHA for ad8dd0e

• Fix races in conductor with dynamic agents (faust-streaming#568)

  Show description for 58b18a1
  

  GodTamIt

  and

  wbarnha

  authored
  58b18a1

  Copy full SHA for 58b18a1

• Consolidate dynamic attributes for setuptools v69.0.0 and move some metadata definitions into pyproject.toml (faust-streaming#574)

  Show description for ddef30e
  wbarnha

  authored
  ddef30e

  Copy full SHA for ddef30e

Commits on Nov 29, 2023

• Fix sdist builds (faust-streaming#577)

  Show description for 2eba690
  wbarnha

  authored
  2eba690

  Copy full SHA for 2eba690

• Add project.scripts to fix faust CLI usage (faust-streaming#580)

  wbarnha

  authored
  6714156

  Copy full SHA for 6714156

• Add description field to pyproject.toml

  wbarnha

  authored
  310eb66

  Copy full SHA for 310eb66

Commits on Nov 30, 2023

• Add FastAPI example (faust-streaming#581)

  Show description for 223b114
  wbarnha

  authored
  223b114

  Copy full SHA for 223b114

• Merge branch 'master' into merge_upstream-06-11-2023

  

  Moser Marco Julian

  committed
  bb643db

  Copy full SHA for bb643db

Commits on Dec 5, 2023

• Bump actions/deploy-pages from 2 to 3 (faust-streaming#582)

  Show description for 2f59442
  dependabot[bot]

  authored
  2f59442

  Copy full SHA for 2f59442

• Rename kafka to aiokafka (faust-streaming#565)

  Show description for 8a5576e
  

  AntonOfTheWoods

  and

  wbarnha

  authored
  8a5576e

  Copy full SHA for 8a5576e

Commits on Dec 7, 2023

• Lint aiokafka driver

  wbarnha

  committed
  73be0a2

  Copy full SHA for 73be0a2

Commits on Dec 8, 2023

• Replace called_once_with test_objects.py for 3.12 support (faust-streaming#586)

  Show description for 53dfd18
  wbarnha

  authored
  53dfd18

  Copy full SHA for 53dfd18

Commits on Dec 9, 2023

• Add official support for Python 3.12 (faust-streaming#587)

  Show description for 3554266
  wbarnha

  authored
  3554266

  Copy full SHA for 3554266

• Update aiokafka requirement from <0.9.0,>=0.8.0 to >=0.8.0,<0.10.0 in /requirements (faust-streaming#583)

  Show description for 1f68fa2
  

  dependabot[bot]

  and

  wbarnha

  authored
  1f68fa2

  Copy full SHA for 1f68fa2

• Bump actions/setup-python from 4 to 5 (faust-streaming#585)

  Show description for a0de373
  dependabot[bot]

  authored
  a0de373

  Copy full SHA for a0de373

Commits on Dec 14, 2023

• Bump github/codeql-action from 2 to 3 (faust-streaming#588)

  Show description for df20a17
  dependabot[bot]

  authored
  df20a17

  Copy full SHA for df20a17

• Bump actions/download-artifact from 3 to 4 (faust-streaming#589)

  Show description for 0628117
  dependabot[bot]

  authored
  0628117

  Copy full SHA for 0628117

• Bump actions/upload-artifact from 3 to 4 (faust-streaming#590)

  Show description for 73fe3e1
  

  dependabot[bot]

  and

  wbarnha

  authored
  73fe3e1

  Copy full SHA for 73fe3e1

Commits on Dec 19, 2023

• Bump actions/deploy-pages from 3 to 4 (faust-streaming#592)

  Show description for 66fd6ba
  dependabot[bot]

  authored
  66fd6ba

  Copy full SHA for 66fd6ba

• Bump actions/upload-pages-artifact from 2 to 3 (faust-streaming#593)

  Show description for 3812158
  dependabot[bot]

  authored
  3812158

  Copy full SHA for 3812158

Commits on Dec 28, 2023

• Add example for medium/large projects in FastAPI (faust-streaming#595)

  hgalytoby

  authored
  6588a97

  Copy full SHA for 6588a97

Commits on Jan 3, 2024

• Use loop.create_task() for agent tasks (faust-streaming#598)

  Show description for 1f1f759
  

  3 peopleauthored
  1f1f759

  Copy full SHA for 1f1f759

• Revert to upload-artifact v3 in python-package.yml

  wbarnha

  authored
  e91c55f

  Copy full SHA for e91c55f

Commits on Jan 9, 2024

• Merge remote-tracking branch 'upstream/master' into aiokafka_KIP_345

  

  Moser Marco Julian

  committed
  37e7a40

  Copy full SHA for 37e7a40

Commits on Jan 11, 2024

• enable kafka static-partition-assignment (KIP-345) (faust-streaming#600)

  Mopsgeschwindigkeit

  authored
  4a09533

  Copy full SHA for 4a09533

Commits on Feb 8, 2024

• Merge branch 'master' into aiokafka_KIP_345

  

  Moser Marco Julian

  committed
  a4e035b

  Copy full SHA for a4e035b