From 8f159f0b018b9b8e88724e8d97dcf3e68093c204 Mon Sep 17 00:00:00 2001 From: marcosschroh Date: Mon, 25 Sep 2023 10:23:53 +0000 Subject: [PATCH] deploy: db1e35124aea664e4a5cfae97eddc52e17962185 --- 404.html | 2 +- backends/index.html | 9 +++--- engine/index.html | 20 ++++++------ getting_started/index.html | 2 +- index.html | 2 +- metrics/index.html | 2 +- monitoring/index.html | 12 ++++--- objects.inv | Bin 446 -> 432 bytes serialization/index.html | 10 ++++-- sitemap.xml.gz | Bin 127 -> 127 bytes stream/index.html | 62 +++++++++++++++++++++---------------- test_client/index.html | 2 +- utils/index.html | 11 ++++--- 13 files changed, 78 insertions(+), 56 deletions(-) diff --git a/404.html b/404.html index db7faef8..04f31a1a 100644 --- a/404.html +++ b/404.html @@ -11,7 +11,7 @@ - + diff --git a/backends/index.html b/backends/index.html index 77db8470..4ddfc21b 100644 --- a/backends/index.html +++ b/backends/index.html @@ -11,7 +11,7 @@ - + @@ -452,6 +452,7 @@

Backends

+

kstreams.backends.kafka.Kafka @@ -511,7 +512,7 @@

ssl_context - Optional[ssl.SSLContext] + Optional[SSLContext]
@@ -720,7 +721,7 @@

bootstrap_servers: List[str] = ["localhost:9092"] security_protocol: SecurityProtocol = SecurityProtocol.PLAINTEXT - ssl_context: Optional[ssl.SSLContext] + ssl_context: Optional[ssl.SSLContext] = None sasl_mechanism: SaslMechanism = SaslMechanism.PLAIN sasl_plain_username: Optional[str] = None @@ -731,7 +732,7 @@

arbitrary_types_allowed = True use_enum_values = True - @root_validator + @root_validator(skip_on_failure=True) def protocols_validation(cls, values): security_protocol = values["security_protocol"] diff --git a/engine/index.html b/engine/index.html index af3bd986..0212528d 100644 --- a/engine/index.html +++ b/engine/index.html @@ -11,7 +11,7 @@ - + @@ -475,6 +475,7 @@

StreamEngine

+

kstreams.engine.StreamEngine @@ -501,7 +502,7 @@

backend - kstreams.backends.Kafka + Kafka
@@ -512,7 +513,7 @@

consumer_class - kstreams.Consumer + Consumer
@@ -524,7 +525,7 @@

producer_class - kstreams.Producer + Producer
@@ -536,7 +537,7 @@

monitor - kstreams.PrometheusMonitor + PrometheusMonitor
@@ -559,7 +560,7 @@

serializer - kstreams.serializers.Serializer | None + Serializer | None
@@ -571,7 +572,7 @@

deserializer - kstreams.serializers.Deserializer | None + Deserializer | None
@@ -1045,8 +1046,9 @@

+

-send(topic, value=None, key=None, partition=None, timestamp_ms=None, headers=None, serializer=None, serializer_kwargs=None) + send(topic, value=None, key=None, partition=None, timestamp_ms=None, headers=None, serializer=None, serializer_kwargs=None) async @@ -1139,7 +1141,7 @@

serializer - kstreams.serializers.Serializer | None + Serializer | None
diff --git a/getting_started/index.html b/getting_started/index.html index 5b8db5ae..1dd4b64b 100644 --- a/getting_started/index.html +++ b/getting_started/index.html @@ -11,7 +11,7 @@ - + diff --git a/index.html b/index.html index a464673b..76508e69 100644 --- a/index.html +++ b/index.html @@ -11,7 +11,7 @@ - + diff --git a/metrics/index.html b/metrics/index.html index 4eb165d3..73f11e37 100644 --- a/metrics/index.html +++ b/metrics/index.html @@ -11,7 +11,7 @@ - + diff --git a/monitoring/index.html b/monitoring/index.html index 180ef742..e08043b9 100644 --- a/monitoring/index.html +++ b/monitoring/index.html @@ -11,7 +11,7 @@ - + @@ -334,7 +334,7 @@
  • - + generate_consumer_metrics() @@ -452,7 +452,7 @@
    • - + generate_consumer_metrics() @@ -516,6 +516,7 @@

      Monitoring

      +

      kstreams.PrometheusMonitor @@ -998,8 +999,9 @@

      -

      -generate_consumer_metrics(consumer) + +

      + generate_consumer_metrics(consumer) async diff --git a/objects.inv b/objects.inv index b6fe9fcff006c7541db07e3124d35f245098a3b2..7696665cce4d33620d6a8898ddb6a36da5484940 100644 GIT binary patch delta 318 zcmV-E0m1&h1F!>-dw;Ez!A`?442JJKMJ2cr#FZ;>f=P%yK;)%fiIO-|oFL%oNm~k~ zTGy`IrD+_0zyH*#4ab1sSZqKUq>_b!tpV{=Ka1VxowC4O+!o#W&E-{bePKEbsnUdE z-E1G5O`mFyry0Rny9T$3RMeiv*q7iP#y3p7@}#2={c5faX@9DwC{ZC{fQV9g;^Z*M zoDj6)fr(K`#-PFKFAOZ!zwdoFT?W)rv*^F@z{Omt2jr8i^m$R@B0E28+ueUAn#jR) zAtfNi+zmM_xes2oEqlccSRjSZnq%G9$*NyaeIY06lFOs6R&Cl+9nJnhCCbBO}sJzLeg4x#NBH~9JR5%8e Q+dPc&v~lAa-x5;^6-B6`=>Px# delta 332 zcmV-S0ki(F1HJ>0dw;c*&rXCe5XSF51&Lm*@#0Jin&sE$bX75bLp|4%uD&Ov>5xe+;YgO?gRX->mgg3EKRlI@?Tv*PDgL7QfmSeI4?V_Q=>)Fo6r e#7)F(>TMM8EsPv~gUT%Ky12~jw8ke9MmCiKKBIX6 diff --git a/serialization/index.html b/serialization/index.html index 36f309da..301ce54b 100644 --- a/serialization/index.html +++ b/serialization/index.html @@ -11,7 +11,7 @@ - + @@ -581,6 +581,7 @@

      Serialization

      +

      kstreams.serializers.Serializer @@ -714,8 +715,9 @@

      +

      -serialize(payload, headers=None, serializer_kwargs=None) + serialize(payload, headers=None, serializer_kwargs=None) async @@ -767,6 +769,7 @@

      +

      kstreams.serializers.Deserializer @@ -877,8 +880,9 @@

      +

      -deserialize(consumer_record, **kwargs) + deserialize(consumer_record, **kwargs) async diff --git a/sitemap.xml.gz b/sitemap.xml.gz index 2f07c4bd70469349e68e19bf7454bb5faeeb61fc..c43e7075815175b0fc726f701983d0e33ea86370 100644 GIT binary patch delta 13 Ucmb=gXP58h;Mfr_IFY>q02}%P_y7O^ delta 13 Ucmb=gXP58h;8^^NYa)9E03K%qcK`qY diff --git a/stream/index.html b/stream/index.html index 5ede6e86..789ff6b6 100644 --- a/stream/index.html +++ b/stream/index.html @@ -11,7 +11,7 @@ - + @@ -402,14 +402,14 @@
      • - + on_partitions_assigned()
      • - + on_partitions_revoked() @@ -436,7 +436,7 @@
        • - + on_partitions_revoked() @@ -463,14 +463,14 @@
          • - + on_partitions_assigned()
          • - + on_partitions_revoked() @@ -723,14 +723,14 @@
            • - + on_partitions_assigned()
            • - + on_partitions_revoked() @@ -757,7 +757,7 @@
              • - + on_partitions_revoked() @@ -784,14 +784,14 @@
                • - + on_partitions_assigned()
                • - + on_partitions_revoked() @@ -831,6 +831,7 @@

                  Streams

                  +

                  kstreams.streams.Stream @@ -879,7 +880,7 @@

                  backend - kstreams.backends.Kafka + Kafka
                  @@ -916,7 +917,7 @@

                  deserializer - kstreams.serializers.Deserializer + Deserializer
                  @@ -928,7 +929,7 @@

                  initial_offsets - List[kstreams.TopicPartitionOffset] + List[TopicPartitionOffset]
                  @@ -940,7 +941,7 @@

                  rebalance_listener - kstreams.rebalance_listener.RebalanceListener + RebalanceListener
                  @@ -1437,8 +1438,9 @@

                  +

                  -__aenter__() + __aenter__() async @@ -1718,6 +1720,7 @@

                  Metrics Rebalance Listener

                  +

                  kstreams.MetricsRebalanceListener @@ -1821,8 +1824,9 @@

                  -

                  -on_partitions_assigned(assigned) + +

                  + on_partitions_assigned(assigned) async @@ -1914,8 +1918,9 @@

                  -on_partitions_revoked(revoked) + +

                  + on_partitions_revoked(revoked) async @@ -2010,6 +2015,7 @@

                  kstreams.ManualCommitRebalanceListener @@ -2095,8 +2101,9 @@

                  -

                  -on_partitions_revoked(revoked) + +

                  + on_partitions_revoked(revoked) async @@ -2217,6 +2224,7 @@

                  Custom Rebalance Listener

                  +

                  kstreams.RebalanceListener @@ -2444,8 +2452,9 @@

                  -

                  -on_partitions_assigned(assigned) + +

                  + on_partitions_assigned(assigned) async @@ -2554,8 +2563,9 @@

                  -on_partitions_revoked(revoked) + +

                  + on_partitions_revoked(revoked) async diff --git a/test_client/index.html b/test_client/index.html index aacb205a..119a149c 100644 --- a/test_client/index.html +++ b/test_client/index.html @@ -11,7 +11,7 @@ - + diff --git a/utils/index.html b/utils/index.html index 3cc7620a..4dc4aa61 100644 --- a/utils/index.html +++ b/utils/index.html @@ -11,7 +11,7 @@ - + @@ -490,8 +490,9 @@

                  Utils

                  +

                  - kstreams.utils + kstreams.utils

                  @@ -515,8 +516,9 @@

                  +

                  -create_ssl_context(*, cafile=None, capath=None, cadata=None, certfile=None, keyfile=None, password=None, crlfile=None) + create_ssl_context(*, cafile=None, capath=None, cadata=None, certfile=None, keyfile=None, password=None, crlfile=None)

                  @@ -722,8 +724,9 @@

                  +

                  -create_ssl_context_from_mem(*, certdata, keydata, password=None, cadata=None) + create_ssl_context_from_mem(*, certdata, keydata, password=None, cadata=None)