README.md
pyproject.toml
src/icestream/__init__.py
src/icestream/__main__.py
src/icestream/logger.py
src/icestream.egg-info/PKG-INFO
src/icestream.egg-info/SOURCES.txt
src/icestream.egg-info/dependency_links.txt
src/icestream.egg-info/entry_points.txt
src/icestream.egg-info/requires.txt
src/icestream.egg-info/top_level.txt
src/icestream/admin/__init__.py
src/icestream/alembic/env.py
src/icestream/alembic/versions/5cc5497d09b5_add_byte_start_end_to_walfileoffset.py
src/icestream/alembic/versions/bf37d72775bc_initial_schema.py
src/icestream/alembic/versions/c354df1a9089_add_log_start_offset_to_partition.py
src/icestream/alembic/versions/d77fb56536a8_use_partition_topic_name_and_number_in_.py
src/icestream/config/__init__.py
src/icestream/db/__init__.py
src/icestream/kafkaserver/__init__.py
src/icestream/kafkaserver/handler.py
src/icestream/kafkaserver/messages.py
src/icestream/kafkaserver/metadata.py
src/icestream/kafkaserver/server.py
src/icestream/kafkaserver/types.py
src/icestream/kafkaserver/handlers/__init__.py
src/icestream/kafkaserver/handlers/api_versions.py
src/icestream/kafkaserver/handlers/metadata.py
src/icestream/kafkaserver/handlers/produce.py
src/icestream/kafkaserver/protocol/__init__.py
src/icestream/kafkaserver/wal/__init__.py
src/icestream/kafkaserver/wal/manager.py
src/icestream/kafkaserver/wal/serde.py
src/icestream/models/__init__.py
tests/test_icestream_integration.py