Kafka：API - 版本历史

Eijux：/* Admin API */

2021-05-19T17:02:55Z

Admin API

←上一版本		2021年5月20日 (四) 01:02的版本
第566行：		第566行：

	== Admin API ==		== Admin API ==
			Admin API 用于'''管理和检查topic、broker、acls和其他Kafka对象'''。


			要使用Admin API，请添加以下Maven依赖关系。
			<syntaxhighlight lang="xml" highlight="">
			<dependency>
			<groupId>org.apache.kafka</groupId>
			<artifactId>kafka-clients</artifactId>
			<version>2.8.0</version>
			</dependency>
			</syntaxhighlight>

			=== 支持的方法 ===
			* alterClientQuotas
			* alterConfigs
			* alterConsumerGroupOffsets
			* alterPartitionReassignments
			* alterReplicaLogDirs
			* alterUserScramCredentials
			* close
			* close
			* createAcls
			* createDelegationToken
			* createPartitions
			* createTopics
			* deleteAcls
			* deleteConsumerGroupOffsets
			* deleteConsumerGroups
			* deleteRecords
			* deleteTopics
			* describeAcls
			* describeClientQuotas
			* describeCluster
			* describeConfigs
			* describeConsumerGroups
			* describeDelegationToken
			* describeFeatures
			* describeLogDirs
			* describeReplicaLogDirs
			* describeTopics
			* describeUserScramCredentials
			* describeUserScramCredentials
			* electLeaders
			* electPreferredLeaders
			* electPreferredLeaders
			* expireDelegationToken
			* incrementalAlterConfigs
			* listConsumerGroupOffsets
			* listConsumerGroups
			* listOffsets
			* listPartitionReassignments
			* listPartitionReassignments
			* listPartitionReassignments
			* listPartitionReassignments
			* listTopics
			* renewDelegationToken

			=== 示例 ===
			==== 创建Topic ====
			<syntaxhighlight lang="java" highlight="">
			// bootstrapServers 如 localhost:9092
			private void createTopics(String bootstrapServers) {
			Properties properties = new Properties();
			properties.put("bootstrap.servers", bootstrapServers);
			properties.put("connections.max.idle.ms", 10000);
			properties.put("request.timeout.ms", 5000);
			try (AdminClient client = AdminClient.create(properties)) {
			CreateTopicsResult result = client.createTopics(Arrays.asList(
			new NewTopic("topic1", 1, (short) 1),
			new NewTopic("topic2", 1, (short) 1),
			new NewTopic("topic3", 1, (short) 1)
			));
			try {
			result.all().get();
			} catch (InterruptedException \| ExecutionException e) {
			throw new IllegalStateException(e);
			}
			}
			}
			</syntaxhighlight>

			==== topic列表 ====
			<syntaxhighlight lang="java" highlight="">
			private void listTopics(String bootstrapServers) {
			Properties properties = new Properties();
			properties.put("bootstrap.servers", bootstrapServers);
			properties.put("connections.max.idle.ms", 10000);
			properties.put("request.timeout.ms", 5000);
			try (AdminClient client = AdminClient.create(properties)) {
			ListTopicsResult result = client.listTopics();
			try {
			result.listings().get().forEach(topic -> {
			System.out.println(topic);
			});
			} catch (InterruptedException \| ExecutionException e) {
			throw new IllegalStateException(e);
			}
			}
			}
			</syntaxhighlight>
			输出：
			<syntaxhighlight lang="java" highlight="">
			(name=topic1, internal=false)
			(name=topic2, internal=false)
			(name=topic3, internal=false)
			...
			</syntaxhighlight>

			==== 增加分区 ====
			<syntaxhighlight lang="java" highlight="">
			Properties properties = new Properties();
			properties.put("bootstrap.servers", bootstrapServers);
			properties.put("connections.max.idle.ms", 10000);
			properties.put("request.timeout.ms", 5000);

			try (AdminClient client = AdminClient.create(properties)) {
			Map newPartitions = new HashMap<>();
			// 增加到2个
			newPartitions.put("topic1", NewPartitions.increaseTo(2));
			CreatePartitionsResult rs = client.createPartitions(newPartitions);
			try {
			rs.all().get();
			} catch (InterruptedException \| ExecutionException e) {
			throw new IllegalStateException(e);
			}
			}
			</syntaxhighlight>

Eijux：/* Connect API */

2021-05-19T16:55:46Z

Connect API

←上一版本		2021年5月20日 (四) 00:55的版本
第560行：		第560行：

	== Connect API ==		== Connect API ==
			Connect API 实现一个连接器（connector），'''不断地从一些数据源系统拉取数据到kafka，或从kafka推送到宿系统'''（sink system）。


			大多数Connect使用者不需要直接操作这个API，可以使用之前构建的连接器，不需要编写任何代码。



	== Admin API ==		== Admin API ==

Eijux：/* Streams API */

2021-05-19T16:52:21Z

Streams API

@@ 第510行： / 第510行： @@
 == Streams API ==
-<syntaxhighlight lang="java" highlight="">
+在0.10.0增加了一个新的客户端库，Kafka Stream。
 </syntaxhighlight>
 == Connect API ==

Eijux：/* Consumer API */

2021-05-19T16:43:40Z

Consumer API

显示更改

Eijux：/* Producer API */

2021-05-19T15:11:57Z

Producer API

显示更改

2021年5月19日 (三) 13:28 Eijux

2021-05-19T13:28:36Z

@@ 第2行： / 第2行： @@
 == 关于 ==
 <syntaxhighlight lang="java" highlight="">
 </syntaxhighlight>

Eijux：建立内容为“category:Kafka == 关于 == ”的新页面

2021-05-17T17:39:27Z

建立内容为“category:Kafka == 关于 == <syntaxhighlight lang="java" highlight=""> </syntaxhighlight>”的新页面

新页面

[[category:Kafka]]

== 关于 ==

<syntaxhighlight lang="java" highlight="">

</syntaxhighlight>

Kafka：API - 版本历史

Eijux：​/* Admin API */

Eijux：​/* Connect API */

Eijux：​/* Streams API */

Eijux：​/* Consumer API */

Eijux：​/* Producer API */