# Kafka Endpoint Properties

## `topic` (string, required)

Any valid topic name addressing a single data-point

Example: `"topic_name"`

## `acks` (number, enum)

Control the number of required acknowledgements. -1 = all insync replicas must acknowledge (default); 0 = no acknowledgments; 1 = only waits for the leader to acknowledge

This element must be one of the following enum values:

* `-1`
* `0`
* `1`

Default: `-1`

## `timeout` (number)

The time to await a response from the broker in milliseconds

Default: `30000`

## `compression` (string, enum)

The compression codec used to compress the messages

This element must be one of the following enum values:

* `None`
* `GZIP`

Default: `"None"`

## `fromBeginning` (boolean)

Only for subscribe: Where to let the consumer start consuming messages. If true, start from the beginning of the topic. If false, start at the end.

Default: `false`


---

# 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.cybus.io/2-1-2/connectors/enterprise-connectors/kafka/kafkaendpoint.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.
