# Kafka Topics

<figure><img src="/files/WLOnutpc52gxueO9Mr8d" alt=""><figcaption></figcaption></figure>

### Overview

The **Kafka Topics** page in Condense provides a management interface to view, create, and configure topics within a Kafka cluster. From this page, administrators can define replication and partitioning, adjust retention policies, and apply advanced topic-level settings without requiring direct Kafka CLI commands.

Path: **Kafka Management → Kafka Topics**

### Topic List

On the left-hand panel, Condense displays all existing topics in the connected Kafka cluster.

* Topics are listed alphabetically.
* A search box allows filtering by topic name.

<figure><img src="/files/EPtqmfZsnvgrgFwY0yg8" alt=""><figcaption></figcaption></figure>

* Selecting a topic loads its configuration details in the main panel.

<figure><img src="/files/fYUzpBrUsErVDdIxcg8p" alt=""><figcaption></figcaption></figure>

### Topic Actions

For each topic, Condense provides the following actions in the top-right menu:

* **Messages** → Opens the message viewer for browsing records in the topic.
* **Edit** → Enables modification of topic configuration.

<figure><img src="/files/ASoiuYMxoZEIoAT9ybpm" alt=""><figcaption></figcaption></figure>

* **Delete** → Permanently deletes the selected topic from the cluster.

<figure><img src="/files/X9DR1OvQs96eHY9B9Unb" alt=""><figcaption></figcaption></figure>

Additionally, the **Create Topic** button allows new topic creation with custom parameters.

<figure><img src="/files/LJh0KBi5PuQhkJHhajjx" alt=""><figcaption></figcaption></figure>

### Basic Configuration

When creating or editing a topic, the following required fields must be defined:

| Field                       | Description                                                               | Example |
| --------------------------- | ------------------------------------------------------------------------- | ------- |
| **Replication Factor**      | Number of replicas for each partition. Ensures data availability.         | `3`     |
| **No of Partitions**        | Number of partitions in the topic. Determines parallelism and throughput. | `6`     |
| **Retention Period (days)** | Duration for which messages are retained in the topic before deletion.    | `7`     |

### Advanced Configurations

Advanced settings allow fine-grained control of topic behavior. These fields map directly to Kafka topic configuration parameters.

| Field                                 | Description                                                                     | Example               |
| ------------------------------------- | ------------------------------------------------------------------------------- | --------------------- |
| **Cleanup Policy**                    | Determines log cleanup strategy. Options: `Delete` (default), `Compact`.        | `Delete`              |
| **Delete Retention Period (days)**    | How long delete markers are retained during log compaction.                     | `1`                   |
| **Max Compaction Lag (ms)**           | Maximum time a record can remain uncompacted.                                   | `9223372036854775807` |
| **Max Message Size (bytes)**          | Maximum size of an individual message allowed.                                  | `5242940`             |
| **Message Timestamp After Max (ms)**  | Upper bound for timestamp range in messages.                                    | `9223372036854775807` |
| **Message Timestamp Before Max (ms)** | Lower bound for timestamp range in messages.                                    | `9223372036854775807` |
| **Message Timestamp Type**            | Defines how message timestamps are set. Options: `CreateTime`, `LogAppendTime`. | `CreateTime`          |
| **Min Compaction Lag (ms)**           | Minimum time a record must remain before compaction.                            | `0`                   |
| **Min In-Sync Replicas**              | Minimum number of replicas that must acknowledge a write for it to succeed.     | `1`                   |
| **Retention Size (bytes)**            | Maximum total size of log segments retained before deletion. `-1` = unlimited.  | `-1`                  |
| **Segment Size (bytes)**              | Size of each log segment file before rolling.                                   | `1073741824`          |
| **Segment Period (ms)**               | Time-based rolling interval for log segments.                                   | `604800000`           |

### Usage Notes

* All advanced fields correspond to Kafka’s topic-level configuration properties.
* Fields not explicitly set in Condense will use Kafka cluster defaults.
* Certain changes (e.g., partition count) are not reversible once applied.
* Care must be taken with retention and cleanup policies to avoid unintended data loss.

### Related Sections

* [Resource Utilization](/condense/condense-app-getting-started/resource-utilization.md)
* [ksqlDB](/condense/condense-app-getting-started/ksqldb.md)


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://docs.zeliot.in/condense/condense-app-getting-started/kafka-topics.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.
