.gitignore
.python-version
MANIFEST.in
Makefile
README.md
alembic.ini
pyproject.toml
pytest.ini
uv.lock
.github/workflows/release.yml
src/icestream/__init__.py
src/icestream/__main__.py
src/icestream/errors.py
src/icestream/logger.py
src/icestream/utils.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/README
src/icestream/alembic/env.py
src/icestream/alembic/script.py.mako
src/icestream/alembic/versions/298875b23096_remove_unnecessary_compaction_columns_.py
src/icestream/alembic/versions/5cc5497d09b5_add_byte_start_end_to_walfileoffset.py
src/icestream/alembic/versions/9f0f8ebe3914_add_min_max_timestamps.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/compaction/__init__.py
src/icestream/compaction/parquet_compactor.py
src/icestream/compaction/schema.py
src/icestream/compaction/types.py
src/icestream/compaction/wal_to_parquet.py
src/icestream/config/__init__.py
src/icestream/db/__init__.py
src/icestream/kafkaserver/__init__.py
src/icestream/kafkaserver/handler.py
src/icestream/kafkaserver/metadata.py
src/icestream/kafkaserver/server.py
src/icestream/kafkaserver/types.py
src/icestream/kafkaserver/utils.py
src/icestream/kafkaserver/handlers/__init__.py
src/icestream/kafkaserver/handlers/add_offsets_to_txn.py
src/icestream/kafkaserver/handlers/add_partitions_to_txn.py
src/icestream/kafkaserver/handlers/add_raft_voter.py
src/icestream/kafkaserver/handlers/allocate_producer_ids.py
src/icestream/kafkaserver/handlers/alter_client_quotas.py
src/icestream/kafkaserver/handlers/alter_configs.py
src/icestream/kafkaserver/handlers/alter_partition.py
src/icestream/kafkaserver/handlers/alter_partition_reassignments.py
src/icestream/kafkaserver/handlers/alter_replica_log_dirs.py
src/icestream/kafkaserver/handlers/alter_user_scram_credentials.py
src/icestream/kafkaserver/handlers/api_versions.py
src/icestream/kafkaserver/handlers/assign_replicas_to_dirs.py
src/icestream/kafkaserver/handlers/begin_quorum_epoch.py
src/icestream/kafkaserver/handlers/broker_heartbeat.py
src/icestream/kafkaserver/handlers/broker_registration.py
src/icestream/kafkaserver/handlers/consumer_group_describe.py
src/icestream/kafkaserver/handlers/consumer_group_heartbeat.py
src/icestream/kafkaserver/handlers/controlled_shutdown.py
src/icestream/kafkaserver/handlers/controller_registration.py
src/icestream/kafkaserver/handlers/create_acls.py
src/icestream/kafkaserver/handlers/create_delegation_token.py
src/icestream/kafkaserver/handlers/create_partitions.py
src/icestream/kafkaserver/handlers/create_topics.py
src/icestream/kafkaserver/handlers/delete_acls.py
src/icestream/kafkaserver/handlers/delete_groups.py
src/icestream/kafkaserver/handlers/delete_records.py
src/icestream/kafkaserver/handlers/delete_share_group_state.py
src/icestream/kafkaserver/handlers/delete_topics.py
src/icestream/kafkaserver/handlers/describe_acls.py
src/icestream/kafkaserver/handlers/describe_client_quotas.py
src/icestream/kafkaserver/handlers/describe_cluster.py
src/icestream/kafkaserver/handlers/describe_configs.py
src/icestream/kafkaserver/handlers/describe_delegation_token.py
src/icestream/kafkaserver/handlers/describe_groups.py
src/icestream/kafkaserver/handlers/describe_log_dirs.py
src/icestream/kafkaserver/handlers/describe_producers.py
src/icestream/kafkaserver/handlers/describe_quorum.py
src/icestream/kafkaserver/handlers/describe_topic_partitions.py
src/icestream/kafkaserver/handlers/describe_transactions.py
src/icestream/kafkaserver/handlers/describe_user_scram_credentials.py
src/icestream/kafkaserver/handlers/elect_leaders.py
src/icestream/kafkaserver/handlers/end_quorum_epoch.py
src/icestream/kafkaserver/handlers/end_txn.py
src/icestream/kafkaserver/handlers/envelope.py
src/icestream/kafkaserver/handlers/expire_delegation_token.py
src/icestream/kafkaserver/handlers/fetch.py
src/icestream/kafkaserver/handlers/fetch_snapshot.py
src/icestream/kafkaserver/handlers/find_coordinator.py
src/icestream/kafkaserver/handlers/get_telemetry_subscriptions.py
src/icestream/kafkaserver/handlers/heartbeat.py
src/icestream/kafkaserver/handlers/incremental_alter_configs.py
src/icestream/kafkaserver/handlers/init_producer_id.py
src/icestream/kafkaserver/handlers/initialize_share_group_state.py
src/icestream/kafkaserver/handlers/join_group.py
src/icestream/kafkaserver/handlers/k_raft_version_record.py
src/icestream/kafkaserver/handlers/leader_and_isr.py
src/icestream/kafkaserver/handlers/leader_change_message.py
src/icestream/kafkaserver/handlers/leave_group.py
src/icestream/kafkaserver/handlers/list_client_metrics_resources.py
src/icestream/kafkaserver/handlers/list_groups.py
src/icestream/kafkaserver/handlers/list_offsets.py
src/icestream/kafkaserver/handlers/list_partition_reassignments.py
src/icestream/kafkaserver/handlers/list_transactions.py
src/icestream/kafkaserver/handlers/metadata.py
src/icestream/kafkaserver/handlers/offset_commit.py
src/icestream/kafkaserver/handlers/offset_delete.py
src/icestream/kafkaserver/handlers/offset_fetch.py
src/icestream/kafkaserver/handlers/offset_for_leader_epoch.py
src/icestream/kafkaserver/handlers/produce.py
src/icestream/kafkaserver/handlers/push_telemetry.py
src/icestream/kafkaserver/handlers/read_share_group_state.py
src/icestream/kafkaserver/handlers/read_share_group_state_summary.py
src/icestream/kafkaserver/handlers/remove_raft_voter.py
src/icestream/kafkaserver/handlers/renew_delegation_token.py
src/icestream/kafkaserver/handlers/sasl_authenticate.py
src/icestream/kafkaserver/handlers/sasl_handshake.py
src/icestream/kafkaserver/handlers/share_acknowledge.py
src/icestream/kafkaserver/handlers/share_fetch.py
src/icestream/kafkaserver/handlers/share_group_describe.py
src/icestream/kafkaserver/handlers/share_group_heartbeat.py
src/icestream/kafkaserver/handlers/snapshot_footer_record.py
src/icestream/kafkaserver/handlers/snapshot_header_record.py
src/icestream/kafkaserver/handlers/stop_replica.py
src/icestream/kafkaserver/handlers/sync_group.py
src/icestream/kafkaserver/handlers/txn_offset_commit.py
src/icestream/kafkaserver/handlers/unregister_broker.py
src/icestream/kafkaserver/handlers/update_features.py
src/icestream/kafkaserver/handlers/update_metadata.py
src/icestream/kafkaserver/handlers/update_raft_voter.py
src/icestream/kafkaserver/handlers/vote.py
src/icestream/kafkaserver/handlers/voters_record.py
src/icestream/kafkaserver/handlers/write_share_group_state.py
src/icestream/kafkaserver/handlers/write_txn_markers.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