kafka默认端口号？

时间: 2023-07-06 14:35:19 浏览: 320

利用docker和docker-compose部署单机kafka

前提 docker docker-compose 其中docker-compose不是必须的,单单使用docker也是可以的,这里主要介绍docker和docker-compose两种方式 docker部署 docker部署kafka非常简单，只需要两条命令即可完成kafka服务器的部署。 docker run -d --name zookeeper -p 2181:2181 wurstmeister/zookeeper docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONN 【知识点详解】本文将详细介绍如何使用Docker和Docker Compose部署单机版Apache Kafka，以及如何进行测试和验证其工作状态。 1. **Docker基础** Docker是一种流行的容器化技术，它允许我们将应用程序及其依赖环境打包成独立的可移植容器，确保应用在任何支持Docker的平台上都能一致地运行。 2. **Docker Compose** Docker Compose是一个工具，用于定义和运行多容器Docker应用。通过YAML文件（docker-compose.yml）配置服务、网络和卷，可以一次性启动整个应用环境。 3. **Kafka与Zookeeper** Apache Kafka是一个分布式流处理平台，而Zookeeper是一个分布式协调服务。Kafka需要Zookeeper来存储集群元数据，因此在部署Kafka之前通常需要先部署Zookeeper。 4. **Docker部署Kafka** 使用Docker部署Kafka非常便捷，只需两步： - 部署Zookeeper容器： ```shell docker run -d --name zookeeper -p 2181:2181 wurstmeister/zookeeper ``` - 部署Kafka容器，连接到Zookeeper： ```shell docker run -d --name kafka -p 9092:9092 \ -e KAFKA_BROKER_ID=0 \ -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \ --link zookeeper \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.1.60:9092 \ -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \ twurstmeister/kafka ``` 这里，`KAFKA_ZOOKEEPER_CONNECT`指定了Zookeeper的连接地址，`KAFKA_ADVERTISED_LISTENERS`和`KAFKA_LISTENERS`则用于设置Kafka的监听地址。 5. **Docker Compose部署Kafka** 如果使用Docker Compose，可以在`docker-compose.yml`文件中定义Zookeeper和Kafka服务，然后运行`docker-compose up`启动它们。这种方式有助于管理和扩展多服务应用。 6. **验证Kafka部署** - 检查容器状态：使用`docker ps`查看Zookeeper和Kafka容器是否正在运行。 - 测试生产者和消费者： - 进入Kafka容器：`docker exec -it kafka sh` - 启动消费者：`kafka-console-consumer.sh --bootstrap-server 192.168.1.60:9094 --topic kafeidou --from-beginning` - 启动生产者：`kafka-console-producer.sh --broker-list 192.168.1.60:9092 --topic kafeidou` 在生产者控制台发送消息，消费者控制台会实时显示。 7. **Java客户端编程** 要使用Java代码与Kafka交互，需要添加Kafka的Maven依赖： ```xml <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.1.1</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>0.11.0.2</version> </dependency> ``` 创建一个简单的生产者示例： ```java import org.apache.kafka.clients.producer.*; // ... public class HelloWorldProducer { // ... public static void main(String[] args) { // ... Producer<String, String> producer = new KafkaProducer<>(props); for (long nEvents = 0; nEvents < events; nEvents++) { // ... producer.send(new ProducerRecord<>(topic, key, value)); } producer.close(); } } ``` 生产者通过`KafkaProducer.send()`方法向Kafka发送消息，这里的`props`包含了连接配置。通过以上步骤，你已经成功部署了单机Kafka，并使用Java代码实现了简单的生产者功能。如果需要扩展为多节点集群或者实现更复杂的应用场景，可以进一步探索Kafka的集群配置和高级特性。

Kafka的默认端口号是9092。这是Kafka broker监听客户端连接的默认端口号，也是Kafka生产者和消费者连接Kafka broker的默认端口号。当然，Kafka的端口号也可以通过修改Kafka配置文件来进行修改。如果你使用了不同的端口号，需要在连接Kafka时指定对应的端口号。例如： ``` bootstrap_servers='localhost:9093' ``` 其中，9093是替换为你实际使用的Kafka端口号。

阅读全文

kafka默认端口号？

相关推荐

kafka参数配置详解

kafka_2.12-3.3.1.tgz

kafka监控工具kafka-eagle

kafka-manager

kafka-eagle

kafka参数说明

最新版kafka kafka_2.12-2.5.1.tgz

erlang-kafka:Erlang 的 Kafka 消费者协议

kafka 2.12安装包，kafka可视化展示工具 eagle 2.0.6

Kafka集群与Kafka-Manager安装教程

Kafka管理工具Kafka-manager的部署指南

linux查看kafka端口

springboot + kafka配置使用ip端口但消费者默认会使用localhost地址是为什么

kafka lisstener

Kafka Manager

kafka删除topic

kafka 扩大分区

kafka 删除topic

最新推荐

2023年第三届长三角数学建模c题考试题目.zip

基于人工智能的毕业设计辅助系统基础教程

平尾装配工作平台运输支撑系统设计与应用

管理建模和仿真的文件

MATLAB遗传算法探索：寻找随机性与确定性的平衡艺术

如何在S7-200 SMART PLC中使用MB_Client指令实现Modbus TCP通信？请详细解释从连接建立到数据交换的完整步骤。

MAX-MIN Ant System：用MATLAB解决旅行商问题

"互动学习：行动中的多样性与论文攻读经历"

【实战指南】MATLAB自适应遗传算法调整：优化流程全掌握

在Spring AOP中，如何实现一个环绕通知并在方法执行前后插入自定义逻辑？