# kafkaTask

**Repository Path**: TengOne/kafka-task

## Basic Information

- **Project Name**: kafkaTask
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-03-27
- **Last Updated**: 2026-05-06

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# kafka-task-worker

kafka-task-worker 是统一任务执行 Worker，负责下载、清洗、文件生成、在线测试与 AutoParse 等 Kafka 命令处理。

```bash
cd worker
export PYTHONPATH=/Users/tf/Documents/worke/tfd/kafka:/Users/tf/Documents/worke/tfd/logging-sdk/src:$PWD
KAFKA_TASK_ENV_FILE=.env.internal /Users/tf/Documents/worke/tfd/api/.venv/bin/python start_consumer.py
```

海外 worker 本地启动：

```bash
cd worker
export PYTHONPATH=/Users/tf/Documents/worke/tfd/kafka:/Users/tf/Documents/worke/tfd/logging-sdk/src:$PWD
KAFKA_TASK_ENV_FILE=.env.overseas /Users/tf/Documents/worke/tfd/api/.venv/bin/python start_consumer.py
```