Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions docs/README.md

This file was deleted.

10 changes: 10 additions & 0 deletions docs/_index.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
---
title: AK 4.1.X
description: Documentation for AK 4.1.X
weight:
tags: ['kafka', 'docs']
aliases:
keywords:
type: docs
---

124 changes: 0 additions & 124 deletions docs/api.html

This file was deleted.

114 changes: 114 additions & 0 deletions docs/apis/_index.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,114 @@
---
title: API
description:
weight: 2
tags: ['kafka', 'docs']
aliases:
keywords:
type: docs
---

Kafka includes five core apis:

1. The Producer API allows applications to send streams of data to topics in the Kafka cluster.
2. The Consumer API allows applications to read streams of data from topics in the Kafka cluster.
3. The Streams API allows transforming streams of data from input topics to output topics.
4. The Connect API allows implementing connectors that continually pull from some source system or application into Kafka or push from Kafka into some sink system or application.
5. The Admin API allows managing and inspecting topics, brokers, and other Kafka objects.
Kafka exposes all its functionality over a language independent protocol which has clients available in many programming languages. However only the Java clients are maintained as part of the main Kafka project, the others are available as independent open source projects. A list of non-Java clients is available [here](https://cwiki.apache.org/confluence/x/3gDVAQ).

# Producer API

The Producer API allows applications to send streams of data to topics in the Kafka cluster.

Examples of using the producer are shown in the [javadocs](/41/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html "Kafka 4.1 Javadoc").

To use the producer, add the following Maven dependency to your project:


<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>4.1.1</version>
</dependency>

# Consumer API

The Consumer API allows applications to read streams of data from topics in the Kafka cluster.

Examples of using the consumer are shown in the [javadocs](/41/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html "Kafka 4.1 Javadoc").

To use the consumer, add the following Maven dependency to your project:


<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>4.1.1</version>
</dependency>

# Share Consumer API (Preview)

The Share Consumer API (Preview) enables applications within a share group to cooperatively consume and process data from Kafka topics.

Examples of using the share consumer are shown in the [javadocs](/41/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaShareConsumer.html "Kafka 4.1 Javadoc").

To use the share consumer, add the following Maven dependency to your project:


<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>4.1.1</version>
</dependency>

# Streams API

The [Streams](/41/streams) API allows transforming streams of data from input topics to output topics.

Examples of using this library are shown in the [javadocs](/41/javadoc/index.html?org/apache/kafka/streams/KafkaStreams.html "Kafka 4.1 Javadoc").

Additional documentation on using the Streams API is available [here](/41/streams).

To use Kafka Streams, add the following Maven dependency to your project:


<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>4.1.1</version>
</dependency>

When using Scala you may optionally include the `kafka-streams-scala` library. Additional documentation on using the Kafka Streams DSL for Scala is available [in the developer guide](/41/streams/developer-guide/dsl-api.html#scala-dsl).

To use Kafka Streams DSL for Scala 2.13, add the following Maven dependency to your project:


<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams-scala_2.13</artifactId>
<version>4.1.1</version>
</dependency>

# Connect API

The Connect API allows implementing connectors that continually pull from some source data system into Kafka or push from Kafka into some sink data system.

Many users of Connect won't need to use this API directly, though, they can use pre-built connectors without needing to write any code. Additional information on using Connect is available [here](/documentation.html#connect).

Those who want to implement custom connectors can see the [javadoc](/41/javadoc/index.html?org/apache/kafka/connect "Kafka 4.1 Javadoc").

# Admin API

The Admin API supports managing and inspecting topics, brokers, acls, and other Kafka objects.

To use the Admin API, add the following Maven dependency to your project:


<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>4.1.1</version>
</dependency>

For more information about the Admin APIs, see the [javadoc](/41/javadoc/index.html?org/apache/kafka/clients/admin/Admin.html "Kafka 4.1 Javadoc").
27 changes: 0 additions & 27 deletions docs/compatibility-summary.html

This file was deleted.

Loading