faust-streaming/faust

Issues

• Remove aredis

  #627 opened 2 months ago by dakotahorstman
  0

• How to check liveness of agent?

  #625 opened 2 months ago by caspereijkens
  6

• StreamT has no filter abstract method

  #626 opened 2 months ago by giulioindev
  0

• Question: Throttle Reconnect Attempts when kafka is unavailable

  #624 opened 2 months ago by jaredvacanti
  1

• normal logging mode

  #623 opened 3 months ago by lubomirmatus
  0

• Wrong offset commit in case of gaps

  #606 opened 5 months ago by vitalbbyy
  0

• 0.10.22 is broken

  #620 opened 3 months ago by Badgerr
  4

• ModuleNotFoundError: No module named 'mode.utils.typing'

  #617 opened 3 months ago by klajdicaushi
  4

• Add a method to include the whole message when using the take method

  #616 opened 3 months ago by fonty422
  1

• Does Faust Streaming Consumer retry the offset commit if it fails?

  #611 opened 4 months ago by arcanjo45
  1

• Logic around sensor _on_stream_event_in differs between cython and python implementations

  #607 opened 4 months ago by Tim-Thomas
  0

• Events getting skipped

  #605 opened 5 months ago by VatsalLalcheta
  1

• Closing connection

  #603 opened 5 months ago by Abraham-liuhai
  0

• Rebalancing problem with Faust Streaming

  #602 opened 5 months ago by arcanjo45
  0

• `SetTable`s are missing `on_clear`

  #601 opened 5 months ago by cristianmatache
  0

• A race condition in recovery causes unrecoverable gaps in acked offsets and consequently blocks committing

  #596 opened 6 months ago by cristianmatache
  0

• Cannot recover when any changelog topic partition becomes empty (as a result of some retention policy)

  #597 opened 6 months ago by cristianmatache
  0

• Rebalancing problem with Faust Streaming consumer

  #594 opened 6 months ago by arcanjo45
  0

• Using debugging mode inside a container is impossible because the console host is not parametrized

  #591 opened 6 months ago by heolin
  0

• 3.12 test compatibility

  #584 opened 7 months ago by AntonOfTheWoods
  0

• Make compatible with new aiokafka

  #566 opened 7 months ago by AntonOfTheWoods
  1

• v0.10.19 -- faust cli is not found in PATH after install

  #579 opened 7 months ago by swelborn
  1

• Source Distribution tar missing for 0.10.18 on pypi.

  #576 opened 7 months ago by kfreezen
  5

• Possible issue with open method when using rocksdict

  #573 opened 7 months ago by fonty422
  12

• Unable to install using Docker on Mac.

  #570 opened 7 months ago by hgalytoby
  5

• (docs) Autodetect for schemas

  #560 opened 7 months ago by redb0
  4

• Conflicting Positional Arguments Using @app.page() Functionality

  #564 opened 8 months ago by ksuden
  1

• Tables don't accept value_serializer kw

  #556 opened 8 months ago by fonty422
  15

• I need to pass arguments to worker

  #554 opened 8 months ago by hlacikd
  2

• Stream.group_by don't support schema

  #552 opened 9 months ago by cmartmos
  3

• (question): signal, when a topic an agent tries to consume from is not present in the kafka cluster

  #558 opened 8 months ago by SDJustus
  6

• Fatal error on startup with documentation examples

  #559 opened 8 months ago by gegnew
  3

• append Content-Type: application/json; charset=utf-8

  #557 opened 8 months ago by hlacikd
  3

• What is test_context?

  #555 opened 8 months ago by Zesky665
  2

• Could you please extend the setting of the webserver to pass parameters?

  #551 opened 9 months ago by cmartmos
  1

• Filtering happens after group_by repartitioning

  #553 opened 9 months ago by dolshevsk
  0

• Faust agent didn't response after long period of inactivity in kafka topic

  #549 opened 9 months ago by Xastur
  0

• Cannot connect to Kafka (MSK) using TLS or IAM based authentication

  #548 opened 9 months ago by vjanz
  1

• Is there a way to assign the number of partitions on table dynamically relying on topic's number of partitions

  #542 opened 10 months ago by dolshevsk
  1

• Faust agents die after some days

  #523 opened a year ago by alihoseiny
  8

• Faust Scaling Approach

  #535 opened 10 months ago by jainal09
  1

• Is python-rocksdb still needed?

  #543 opened 10 months ago by turangojayev
  2

• Commit structure validation failure: TP != TopicPartition

  #539 opened 10 months ago by richardhundt
  13

• How to use generic records?

  #526 opened a year ago by SergiusAC
  1

• FR: Support for Pulsar streams

  #537 opened a year ago by adyanth
  0

• Synchronous Sending

  #536 opened a year ago by andrewgy8
  6

• sometimes Task timed out and all consumer stopped

  #532 opened a year ago by joonjeong
  0

• Running with isolated_partitions and more than 1 worker crashes

  #529 opened a year ago by ostetsenko
  1

• ## [Codecov](https://app.codecov.io/gh/faust-streaming/faust/pull/510?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=faust-streaming) Report

  #528 opened a year ago by Babo0o
  0

• NoAck and Manual Acknowledgement not working in case of Exception in agent and Rebalancing

  #527 opened a year ago by xcarlosamm
  0