CHANGELOG.md,sha256=btsSB2dNWGst_ZC62HP9Pm2CQAJipwdAMdugywdBbKc,33933
LICENSE,sha256=Q_5s2f12dx9yxtBxiDkxTxK4E-oBnXXvf-BAXH_932o,1208
README.md,sha256=eQQ2FtMRfUV1qCj9wSxBRxoEW4HnWoVBTwAAuJJRhHE,35290
django_kafka/__init__.py,sha256=L8jL_cqePV7woccbG4qXarKGtxxYIeS8pmN6DQaQWR8,2194
django_kafka/admin.py,sha256=zw-ESCCmmkh1oxA-2dApQ8ovJrD3VDCU2dOyYoH4XTk,768
django_kafka/apps.py,sha256=7j8d7r3svojXITTO-r7RKMVnjvJrOU3dg38o5p93yPQ,236
django_kafka/conf.py,sha256=Taz_B53D51jXqQjvMMx8ygGuurEswKCuTpjPhXPHa9c,3171
django_kafka/error_handlers.py,sha256=pAzVKZbazQGe6zkefca_2iV8R03PCPROoYj9TbDloeM,232
django_kafka/exceptions.py,sha256=LaHtBlb3H0sLl3VXUeQ2dQv5XAdHOUh3Nb7R-GMzz8g,262
django_kafka/producer.py,sha256=1RL6g-GAMeMD_JpRD_giRsBr_xdVi_c-DMbwx3sZGyU,3965
django_kafka/py.typed,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/registry.py,sha256=lK_pO5ZP1Z6b_8Pn89c3gFdmmPe1ClhgHTYZpAeASBo,1915
django_kafka/serialization.py,sha256=vrc24C7OrrNEP-f1CAkEpVZMEXzflvJvVNYA4Oqpm7Y,237
django_kafka/connect/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/connect/client.py,sha256=I1c_7CjovqneLnX0Vkoy8tJwr5Z9S941O8Xn5jflEmk,2295
django_kafka/connect/connector.py,sha256=Ug1emJlaAf-W_6uL-Lt11EZYqEWat4G7O3-b4a6alUY,3040
django_kafka/connect/models.py,sha256=sfwFvntLb3IqitjoUk1qrza-gPiV6U_LLZ9MSJjK4TU,4550
django_kafka/consumer/__init__.py,sha256=1FplxDtjSx2z6sqYbyDBupPfAl1asRBEMcLUBw5gXmE,103
django_kafka/consumer/consumer.py,sha256=Yh2z9b0f283P_w652XoSDIgouoMG-mY9ggxEBWiyV10,10807
django_kafka/consumer/managers.py,sha256=ooV4Xhitw8J7QIpz8f9iCBQ6qgF6To6Zi69N-l6Aeik,2249
django_kafka/consumer/runner.py,sha256=mhnQDUH7I-J63YqyQW8wyfgnpdBB6ilC69g_lEIjnCs,3913
django_kafka/consumer/topics.py,sha256=5XRf2mrAmvrSOYNPUjVyAHb4Nte1ihbOrWOFtHUYMrk,2374
django_kafka/dead_letter/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/dead_letter/header.py,sha256=QC780WLQdx0UY66HG7Paf1VZxw3o-eFkNWViJ6wS2U8,304
django_kafka/dead_letter/topic.py,sha256=YwauXntoj15u5Foavaiwe-Sv5d5k_0BEsaUkLC7-ypE,1520
django_kafka/locale/de/LC_MESSAGES/django.po,sha256=phRP1BECnnvyz_UJKAAufX9Ble2sw7NqxQtHITs3kk0,2679
django_kafka/management/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/management/commands/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/management/commands/errors.py,sha256=5N1vZfFnS7zOwlw26GZ_YQpImz44EZod96jm-N8sPOw,503
django_kafka/management/commands/kafka_connect.py,sha256=-GyP_QWOHCTwcIDpbkcNHGKhuksorCu87YWDTdvbcX0,7590
django_kafka/management/commands/kafka_consume.py,sha256=11T7aIKrWrdMeUckONNvdMgjQv_6iex_DySv7MuhPPk,663
django_kafka/migrations/0001_initial.py,sha256=6RK4zxkwAW_FtyA2n-_kKYP3bzmD7Op1POzWVNx83aY,1143
django_kafka/migrations/0002_waitingmessage.py,sha256=4W9WX-C7xmpQ6Xt4aT9SzYdA7f_SCvHehr-SftGtuOw,1712
django_kafka/migrations/0003_alter_waitingmessage__headers.py,sha256=qy_QXwkqvbfdBD9bCkPdR--8yDMzei0ZfNKRraE7iH4,429
django_kafka/migrations/0004_waitingmessage_django_kafka_topic_key_idx.py,sha256=aYcxGGpqOQ0ww4Nh9dk0BaK6GH2fsZ4cwWbiC8xe8CY,422
django_kafka/migrations/0005_waitingmessage_django_kafka_relation_idx.py,sha256=vdX58llMxiftGPNN7AXcpje7XNy3lcelvS2wbz-v0f4,481
django_kafka/migrations/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/models/__init__.py,sha256=-6ZAzwAsdfxSd6mwuKsObOVKRPRJJ3knIsZDpQ94dpM,7390
django_kafka/models/model_sync/__init__.py,sha256=s9CxqXlB0nbpqQxn6EshAGkx_E0x4ZKgY-kivFmNxYQ,1307
django_kafka/models/model_sync/descriptor.py,sha256=hAKxEuEoh1MkPiZf5DJC68CsP9dJKSTC0SL6bA5aP8Q,858
django_kafka/models/model_sync/enricher.py,sha256=spMCbRj58h-VmsJ97aVoWLu-FVC5PlfqycGxQJ2pLE8,5004
django_kafka/models/model_sync/fields.py,sha256=yqUPdEwJi4s1WZ3_b5KHRXl9k2FRBXGv2a7knqKrGeY,74
django_kafka/models/model_sync/registry.py,sha256=2ZB8AXpi3r4kH1YfzDiq-UPtXLglB_V7JLy_f3fnGwo,4586
django_kafka/models/model_sync/sync.py,sha256=Nbpj7U_HPO717IM4XcCutUtF-32KqWUUhATtGJzy6uA,5597
django_kafka/models/model_sync/transforms.py,sha256=_iI_flCSG0LnzEECq4ZYSReA6hoPhCh-D5cMo_Dk1yQ,14097
django_kafka/models/model_sync/sink/__init__.py,sha256=hUKkOuzH7Fl0NIn4Ezwy1PMpJTjl3iGjsVVwv3N0_RM,374
django_kafka/models/model_sync/sink/base.py,sha256=nsjghRhMp-LzsPSxtQ3lFRu0sNC1basWIF6-NRenne8,396
django_kafka/models/model_sync/sink/dbz_jdbc.py,sha256=7LE9LHTs5boWmF6xQVI8kO91dAuPcGn5ryPF5MMlpTA,7184
django_kafka/models/model_sync/sink/python/__init__.py,sha256=Y3U7ydtSP9-CJoiFxgxdMXXdCnf7YO1qOygb1c7G5Is,370
django_kafka/models/model_sync/sink/python/sink.py,sha256=K1YEK4HL3EId47umdKGGpvK-qUgF4NDHjr9L3VLAFdM,3883
django_kafka/models/model_sync/sink/python/topic.py,sha256=MisgxgoAwN_oO70TMUwRq238AR3yjOqOQC4YQXQF4Uc,6570
django_kafka/models/model_sync/source/__init__.py,sha256=AicyoTOJHL4YXu6mrKYwdMxCbHIT6jV0jc0uEaWk38U,237
django_kafka/models/model_sync/source/base.py,sha256=JTZDuH8lKIDiEIhkpiRlQgppVekw7xfeCP-Woo1KCSw,675
django_kafka/models/model_sync/source/dbz_postgres.py,sha256=byLPjehVnNR-agZgnr5J2KiY2izg90UkQsVq5nq66FI,6497
django_kafka/relations_resolver/__init__.py,sha256=tjGGxWXxMGl7k5DLt6ifICp4jBLNst2_kdUwunz0nL8,53
django_kafka/relations_resolver/relation.py,sha256=7uxQ7W0tZ6lC0vETo5_EGkmkkkMONQNCmXG9Mf9pghs,3141
django_kafka/relations_resolver/resolver.py,sha256=XRLeBfpM7lh8osHfcXo8MIr15frdiKnb3XQRH6jJ3Fg,3297
django_kafka/relations_resolver/daemon/__init__.py,sha256=0T4ss50MXZF1YOzdd4IjTqQaoer6-uJkdFvGZjRVzAY,945
django_kafka/relations_resolver/daemon/temporal.py,sha256=zRqSBaarI9VJ0ZIC9-Jx1BJOHm7aF64GtrtahHmady4,849
django_kafka/relations_resolver/processor/__init__.py,sha256=cq21EQgYWt_Y7hG10uRBg4Ta30RixhGdOar2_o96ORY,491
django_kafka/relations_resolver/processor/base.py,sha256=8L0tZmDpVRqwmieqjohVn4bV89u-0GcRI87xlwA3Op8,991
django_kafka/relations_resolver/processor/model.py,sha256=P51i5uGEhY8pocGMawD4xjsyu0y8DCB5kV0TJdMpmvw,4363
django_kafka/relations_resolver/temporalio/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/relations_resolver/temporalio/activities.py,sha256=f4UWB91DkY6gCLKOdQIbPIxWPVPapyoiLOuExmVzRqw,908
django_kafka/relations_resolver/temporalio/schedules.py,sha256=iUKcpcFfWnRN3PtISrFxMl6FMRDySVF9effTIKzVNUo,724
django_kafka/relations_resolver/temporalio/workflows.py,sha256=gOXerSyJbOR2e45FJhUx6_xiMvQaM37ldfHmzqdcKC4,1439
django_kafka/retry/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/retry/consumer.py,sha256=SpXeoAKL4SE2BvggTCOn26xKwzLjTuV6bw-7K6snAFA,2551
django_kafka/retry/header.py,sha256=fZ8bODwpVz9AcdByPUAEg7ZbpYwmn0eN_F0YeRYSH-M,670
django_kafka/retry/settings.py,sha256=jLXjVMiePyOf4hqcma8NVKugeoXmzRxjpf4BvLpObBM,3458
django_kafka/retry/topic.py,sha256=O5FwiEG0StCcBStEjHhgsUH-EoaUW2RSaIJ6h_UftKI,3748
django_kafka/retry/tracker.py,sha256=wqXRKeFDwBleiHUmxM6iiLOmnXGm_I7bXpa1CO96EFA,2039
django_kafka/schema/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/schema/avro.py,sha256=2C-gYfQn1Zpf50a37gHyQ71-b2EgAtgdFE5lUQ3pQEQ,7311
django_kafka/schema/fields.py,sha256=laBfAo51vXEO0JCegQGvCIAZ3NbCg1jHNYYtztjKh3A,3284
django_kafka/tests/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/models.py,sha256=QFVIx9hyLg6p2Pu7oj8OD_nrPw-NI0WjbuCCIXhl1qo,944
django_kafka/tests/test_django_kafka_interface.py,sha256=dWy_hp8O9NkiqUycIkuixbwy8YI-YJZrXae2tQfxg-w,2159
django_kafka/tests/test_registry.py,sha256=H-zEvAi2xXBC7RztYT9MlbgTNUl6Wx3dp5KsFkLyHrk,4176
django_kafka/tests/test_settings.py,sha256=r5l8YSqvBtDVwVWOvinHQR2jrr_RVnyPswwgfWX3QqE,3008
django_kafka/tests/utils.py,sha256=l1RlzVxs4EIgPJPSdUEYVGHBVeRvEpDdcYPWhaCisNQ,1228
django_kafka/tests/relations_resolver/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/relations_resolver/factories.py,sha256=l1tlpQw5CNw758AcRHKK5xGjjtOx3PTfNTsybpQ3Gfw,709
django_kafka/tests/relations_resolver/test_model_processor.py,sha256=l_bYugA-_IeohrsghWgFgj5CHbZh8ukSixrh1Z_v7fE,11453
django_kafka/tests/relations_resolver/test_model_relation.py,sha256=-um7M-vTGnnLs0qa4ZhPO6YyihpByP7ikzdJhmAuQr0,2088
django_kafka/tests/relations_resolver/test_queryset.py,sha256=B8rOzG9AglNZXCYMyq1tGmdUt1z0FYbDPOR6lIOt2R4,6659
django_kafka/tests/relations_resolver/test_relation.py,sha256=oIr9aR36mD8S4CcJIUgbdKfTPgKjTZOPZ23H1J7TBtI,2911
django_kafka/tests/relations_resolver/test_relation_type.py,sha256=ZGC-dtcvL21UBxfII5_H-qI9L59diqqC_cF-Wi_3v6U,902
django_kafka/tests/relations_resolver/test_resolver.py,sha256=BHtn3VVssDCtynfYZVoB3TW_CB_vtz5jETqiPuUYxrw,5366
django_kafka/tests/test_connect/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_connect/test_client.py,sha256=XwDyzJnh1Z5-Fz6kFM3TijDxFRF9S-TrbW7eJPRWBoI,4608
django_kafka/tests/test_connect/test_connector.py,sha256=tqk5Acrj4lLLRt1Dr7S-epO-x_NPS40Qk5dzLDifc38,6033
django_kafka/tests/test_connect/test_kafka_connect_command.py,sha256=bYwvjBymDyassP9AE2UzgqzoY_BNf0eBW1zrZZX3lxo,7719
django_kafka/tests/test_connect/test_models.py,sha256=4iQBhmBI5tQ9zMwo7j5jq3qF5J6Af7vRNIqpbyNcDU4,7616
django_kafka/tests/test_connect/test_substitute_error.py,sha256=GkkQCD4Wp4Pr8mEjKahyPW-48DMkC71TX1SJ3_vYD0k,723
django_kafka/tests/test_consumer/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_consumer/test_consumer.py,sha256=fFxhhDOOL19KChLhmAvAGFE7KbagR-m9G-t1tn-0PGw,21581
django_kafka/tests/test_consumer/test_managers.py,sha256=VvB_sVdEVsCv8HHvKFbFbTSPlcfnV1JCZGKwUGwDKtQ,2491
django_kafka/tests/test_consumer/test_topics.py,sha256=l7FZgjGhQlP6l7RCcnahP1tt0g9oHb30GYoFYlQEqZg,699
django_kafka/tests/test_dead_letter/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_dead_letter/test_topic.py,sha256=33se1m1OA7sZg5GLDlYR3cmClLkwWymg8LvBHiQeZPk,2107
django_kafka/tests/test_models/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_models/test_model_sync/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_models/test_model_sync/factories.py,sha256=nR0FSP_frf7GqPxw_ZrZ_nMJ3ABQ2LA5HbzuY9qZRis,2338
django_kafka/tests/test_models/test_model_sync/test_consumer_integration.py,sha256=_19dfGtJvJaNNBecBGqTB9NrQfwE-6J9_Z2nDBmcjYY,1571
django_kafka/tests/test_models/test_model_sync/test_enricher.py,sha256=0SDJ5ALG3LvyX-ElKInJ7OVnlF-j5wIQgg5ts9PBzPA,5168
django_kafka/tests/test_models/test_model_sync/test_python_sink.py,sha256=xby2V2XwpuklDm5aJG5H9IdQe-gqbQuBXx_9n6HQI6o,7495
django_kafka/tests/test_models/test_model_sync/test_registry.py,sha256=KXOyDRk99mzB_E_0wDhqrXZ4sHPRIhGN5CoQyl_fyyY,1608
django_kafka/tests/test_models/test_model_sync/test_sink.py,sha256=Zq0_DwdKuFIj_UhcpHo7yOrIC5ccVBhJym1PQe4lay4,3719
django_kafka/tests/test_models/test_model_sync/test_source.py,sha256=cGsEiChTGntHdHO4j9iIY1xdOJamEBhjh_MfJ1WEkl8,5229
django_kafka/tests/test_models/test_model_sync/test_sync.py,sha256=-1UDnvi24Ahl-UTDtZSDbwCDaJBSAI0DIwbP8HJqYuM,4370
django_kafka/tests/test_models/test_model_sync/test_transforms.py,sha256=UXc0ep0DoPf0Pz_7l3eH6IrOgFiMA73N4ZGDDlj4LMs,1261
django_kafka/tests/test_retry/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_retry/test_consumer.py,sha256=VQb2vvay1kTX4s8UJ8JhrPRStRcm6GKFYZMoEJVHdb0,7340
django_kafka/tests/test_retry/test_headers.py,sha256=1Mp5yRa2rmgfXTIJCXvTqpaE0lzX1ztEcCVGF66OPTg,732
django_kafka/tests/test_retry/test_key_offset_tracker.py,sha256=DQH-WrHuG3UBuxvtdYKGpjdeveGcEbl7cgA32zoGPfc,9842
django_kafka/tests/test_retry/test_retry.py,sha256=Y1NTSaESMD44-vjKU-Jm-qc_M3aQXbRrulA8Ps1A8YI,6276
django_kafka/tests/test_retry/test_topic.py,sha256=i_AGNPf5PdOc6BuDM-4tp66gLFhUWLBiMddYq3Nz8e0,9216
django_kafka/tests/test_schema/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_schema/test_avro.py,sha256=aD4UaOHSva_-zTrjKrdmO2AfAKblHpYgZ41dPYDRDD0,12374
django_kafka/tests/test_topic/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_topic/test_avro.py,sha256=h2GBF9AlNaAHgyeUXETecIziwKMAo6gOoA52MnSqqYE,3434
django_kafka/tests/test_topic/test_debezium.py,sha256=RPp8D_HXruwjPXW4Md__JQ79t96l763mCSlgiH09z2w,3677
django_kafka/tests/test_topic/test_model.py,sha256=hlbx0hkn47B4jEEtNYrxybGtQ4Np-Am8CgFU_U8X1YE,5757
django_kafka/tests/test_topic/test_reproducer.py,sha256=miZp7D5O94wAKGrG4btLWyTMNR_h8BRNGlh7LRyGsY0,5109
django_kafka/tests/test_topic/test_topic.py,sha256=8HhltxQ5Rk0kg-9EyBOToKgBXAJ9ZQRQHqBGh-DQScc,13567
django_kafka/tests/test_topic/test_transforms.py,sha256=NN2yXQZu5q8vx5FdCpN8U9h2xuh91qUZMBqG-wvY97Y,637
django_kafka/tests/test_utils/__init__.py,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
django_kafka/tests/test_utils/test_message.py,sha256=MviRqxDGsI2vOHUFiC5GW6sh9fAC7bXaGJIQk5jfTNU,545
django_kafka/topic/__init__.py,sha256=b50HHeloyWml_uBw_y0jUUVKnE33NmH4jf8JdK_p5e4,5507
django_kafka/topic/avro.py,sha256=UqEpw_ZhdtRzBFmAJ22nfuTyJHmBaSYb1gb8QxH2hQ8,2335
django_kafka/topic/debezium.py,sha256=59jBWbGWl39henQoo_ESahrZho_Whau7N-yklAoOWBA,1393
django_kafka/topic/model.py,sha256=j7XW6GbwuaxDS8yVWw-PxFf7DLSWhMiGExGFcodHKZI,3816
django_kafka/topic/reproducer.py,sha256=v8VtyZE9wSWyVAQPJvcUN-oR3E_gC6LU3dhp8t106Mo,4217
django_kafka/topic/transforms.py,sha256=6LfeQ78mGJBagCnoNIYObRVLSpFFwJOKtTmH2vjyEZs,469
django_kafka/utils/__init__.py,sha256=1RqP4Kt8EvpzgKAMOaRk1d7lFJffv3eBuXXr6yXJxiU,53
django_kafka/utils/message.py,sha256=DtrYHbqv8gW8uFcIzLIkKgXq1rlzDuEAGpdm8lxQInY,2609
django_kafka/utils/retry.py,sha256=_ur-kTW4B9KPmLgJGTxEhMQ-8DbqDfo14OcHysP22IE,679
django_kafka-2.0.0.dist-info/METADATA,sha256=DcAFoaWRXNZjaXxnAPYl5_VrQBQrJSwlvgrdc4J8mv8,36832
django_kafka-2.0.0.dist-info/WHEEL,sha256=lCkmxWfQsSc9CfIClYeavTdQeEX2toPqufh9gI35EQA,87
django_kafka-2.0.0.dist-info/licenses/LICENSE,sha256=Q_5s2f12dx9yxtBxiDkxTxK4E-oBnXXvf-BAXH_932o,1208
django_kafka-2.0.0.dist-info/RECORD,,
