You need to enable JavaScript to run this app.
最新活动
产品
解决方案
定价
生态与合作
支持与服务
开发者
了解我们

kafka的web默认端口号

Kafka是一款高性能、分布式、基于发布/订阅模式的消息队列系统。它通过将消息存储在多个分区中,实现了高可靠性和高吞吐量。Kafka提供了多种接口,包括Java API、REST API以及CLI工具等,方便用户进行数据的写入和读取。本文将着重讲述Kafka的Web默认端口号。

Kafka的Web默认端口号为9092。这个端口号通常用于连接Kafka Broker,生产者和消费者通过连接到这个端口来发送和接收消息。在Kafka配置文件server.properties中,可以看到以下默认配置:

# The port the socket server listens on
port=9092

由此可知,Kafka的Web默认端口号是9092。

下面是Java代码示例,展示如何使用Kafka的Java API连接到默认端口号9092:

import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class KafkaProducerExample {
    public static void main(String[] args){
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
        
        Producer<String, String> producer = new KafkaProducer<>(props);
        String topic = "test-topic";
        String key = "key";
        String value = "Hello, Kafka!";
        producer.send(new ProducerRecord<>(topic, key, value));
        
        producer.close();
    }
}

上述代码示例中,我们使用Kafka的Java API创建了一个生产者,并将消息发送到了名为test-topic的主题中。在API使用中,我们通过指定bootstrap.servers属性来指定Kafka Broker的主机和端口。在这里,我们指定了localhost:9092,即使用默认端口号连接到本地的Kafka Broker。

总结来说,Kafka的Web默认端口号为9092。通过Java API的调用示例,我们可以看到如何使用默认端口号连接到Kafka Broker,并使用生产者向指定主题发送消息

本文内容通过AI工具匹配关键字智能整合而成,仅供参考,火山引擎不对内容的真实、准确或完整作任何形式的承诺。如有任何问题或意见,您可以通过联系service@volcengine.com进行反馈,火山引擎收到您的反馈后将及时答复和处理。
展开更多
基于 Apache Kafka 构建,提供高可用、高吞吐量的分布式消息队列服务

社区干货

Logstash 如何通过 Kafka 协议消费 TLS 日志

# **问题现象**如何通过修改 Logstash 配置文件,实现通过 Kafka 协议消费日志到其他业务系统。# 问题分析TLS 日志服务支持通过 Logstash 消费日志数据,您可以通过配置 Logstash 服务内置的 logstash-input-kafk... 建议使用 IAM 用户的 AK,且 IAM 用户应具备 Action PutLogs 的权限。详细信息请参考[可授权的操作](https://www.volcengine.com/docs/6470/103038)。 || hosts | 初始连接的集群地址,格式为`服务地址:端口号`,例如...

云原生环境下的日志采集、存储、分析实践

OpenTelemetry 和 Kafka 协议上传日志。支持多种类型的终端、多种开发语言以及开源生态标准协议。采集到的日志首先会存入高速缓冲集群,削峰填谷,随后日志会匀速流入存储集群,根据用户配置再流转到数据加工集群进... 火山引擎上 Web 配置由 OP 来负责,容器自动化采集是用 CRD 的方式,一般是 RD 负责。*Q2:采集端 Agent 的使用资源可以限制吗?是否会影响业务的资源使用?*A:CPU 占用量、内存占用量这些是可以配置的,不会影响业务...

云原生环境下的日志采集、存储、分析实践

OpenTelemetry 和 Kafka 协议上传日志。支持多种类型的终端、多种开发语言以及开源生态标准协议。采集到的日志首先会存入高速缓冲集群,削峰填谷,随后日志会匀速流入存储集群,根据用户配置再流转到数据加工集群进... A:日志采集的中心化配置是 Web 方式,配置非常简单,无论是 RD 或是 OP 负责都可以。火山引擎上 Web 配置由 OP 来负责,容器自动化采集是用 CRD 的方式,一般是 RD 负责。Q:采集端 Agent 的使用资源可以限制吗?是否会...

集简云5月新增/更新:新增6大功能,21款应用,更新17款应用,新增近160个动作

新增应用:Kafka连接器新增应用:Airtable **应用更新**更新应用:企业微信(代开发)更新应用:易快报 更新应用:每刻报销 更新应用:北森 更新应用:有赞商城(第三方... 选填字段默认折叠展示在下方。当用户需要使用选填字段时,可以通过点击按钮添加需要的字段。详细文章见:[【新增功能】选填字段自动分类折叠——让字段配置更高效](http://mp.weixin.qq.com/s?__biz=Mzg5MjcxOD...

特惠活动

企业直播体验福利包

20G存储+3000分钟时长,乐享1个月
0.00/0.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

kafka的web默认端口号-优选内容

实例连接
消息队列 Kafka版提供以下实例连接相关的常见问题供您参考。 FAQ 列表是否支持修改 VPC 和子网? 是否支持修改实例的连接地址和端口号? SSL 证书的有效期是多久? 是否支持无密码访问 Kafka 实例? 是否支持跨 VPC 或... 消息队列 Kafka版服务端会维护并定期更新 SSL 证书,保证 SSL 证书的长期可用性。 是否支持无密码访问 Kafka 实例?支持,VPC 内通过默认接入点访问实例时,无需传输过程加密与身份认证,也不需要密码或鉴权。具体操作请...
使用默认接入点连接实例
本文介绍在 VPC 网络环境下通过默认接入点连接 Kafka 实例,进行消息生产和消息消费的操作步骤。 背景信息消息队列 Kafka版提供 PLAINTEXT 协议的普通访问方式,即默认接入点。在 VPC 网络环境下通过默认接入点连接实例时,无需配置用户名及密码,直接访问即可。 前提条件已获取默认接入点信息,包括连接地址和端口号。详细信息请参考查看接入点。 已创建 Topic。操作步骤请参考创建 Topic。 已购买火山引擎 ECS,并成功安装 JDK、配置...
Kafka订阅埋点数据(私有化)
本文档介绍了在增长分析(DataFinder)产品私有化部署场景下,开发同学如何访问Kafka Topic中的流数据,以便进一步进行数据分析和应用,比如实时推荐等。 1. 准备工作 kafka消费只支持内网环境消费,在开始之前,需要提前准备好如下输入: Kafka 0.10.1版本及以上的客户端(脚本或JAR包) zookeeper链接:可联系运维获取 broker链接:可联系运维获取 topic名称:下方给出了两个topic数据格式,确认需要消费哪一个topic; ConsumerGroup:确认好Co...
Kafka订阅埋点数据(私有化)
本文档介绍了在增长分析(DataFinder)产品私有化部署场景下,开发同学如何访问Kafka Topic中的流数据,以便进一步进行数据分析和应用,比如实时推荐等。 1. 准备工作 kafka消费只支持内网环境消费,在开始之前,需要提前准备好如下输入: Kafka 0.10.1版本及以上的客户端(脚本或JAR包) zookeeper链接:可联系运维获取 broker链接:可联系运维获取 topic名称:下方给出了两个topic数据格式,确认需要消费哪一个topic; ConsumerGroup:确认好Co...

kafka的web默认端口号-相关内容

Kafka Exporter 接入

托管 Prometheus 服务提供基于 exporter 的方式来监控 Kafka 运行状态,本文为您介绍如何在集群中部署 kafka-exporter,并实现对 Kafka 监控。 前提条件已注册并开通火山引擎容器服务(VKE)。 已创建托管 Prometheu... kafka-exporter 根据业务需要调整成对应的名称,建议加上 Kafka 实例的信息 spec: containers: - args: - --kafka.server=x.x.x.x:9092 配置 Kafka 实例的地址和端口号 image: dan...

使用 SASL_PLAINTEXT 接入点连接实例

默认情况下可以通过 VPC 内访问 Kafka 实例,开启公网访问功能之后,还可以通过公网访问实例。两种网络类型均可以通过 SASL_PLAINTEXT 接入点进行接入。如果公网环境下访问实例需要通过 SSL 认证,推荐选择 SASL_SSL 接入点,详细接入方式请参考使用 SASL_SSL 接入点连接实例。 前提条件已获取 SASL_PLAINTEXT 接入点信息,包括连接地址和端口号。详细信息请参考查看接入点。 已创建 Topic。操作步骤请参考创建Topic。 如果通过公网访...

高阶使用

本文将为您介绍火山引擎 E-MapReduce(EMR)kafka 组件相关的高阶使用,方便您更深入的使用 Kafka。 扩容 您可以在 EMR 控制台的集群管理页面,进行 Kafka 集群的扩容操作。开源 Kafka 扩容新的 broker 后,流量不会自动... Kafka 集群在创建时如果给 Broker 所在的 Core 节点组绑定了公网 IP,会自动配置 Kafka Broker 的 advertised.listeners 等参数,使 Kafka Broker 可以通过公网 IP(端口号:19092)和内网地址(端口号:9092)访问。在 ...

企业直播体验福利包

20G存储+3000分钟时长,乐享1个月
0.00/0.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

通过 Kafka 协议消费日志

password Kafka SASL 用户密码。应配置为火山引擎账户密钥。格式为 ${access-key-id}${access-key-secret},其中: ${access-key-id} 应替换为您的 AccessKey ID。 ${access-key-secret} 应替换为您的 AccessKey Secret。 说明 建议使用 IAM 用户的 AK,且 IAM 用户应具备 Action ConsumeLogs 的权限。详细信息请参考可授权的操作。 hosts 初始连接的集群地址,格式为服务地址:端口号,例如 tls-cn-beijing.ivolces.com:9093,其...

快速开始

2 Kafka 节点部署说明在 Kafka 集群中,Kafka Broker 部署在集群的 Master/Core 节点中,而 ZooKeeper 共三个节点,部署在集群的 Master 和 2 个 Core 节点中。在集群初始化的过程中,Kafka 集群的各个服务便会依次启... 系统会自动把相关的公网 IP 配置信息写入到 Kafka Broker 的 advertised.listeners 服务参数中。这时 Kafka Broker 可以通过公网 IP(端口号:19092)和内网地址(端口号:9092)访问。 3.1.2 创建集群成功后,再绑定公网...

使用 Kafka 协议上传日志

初始连接的集群地址,格式为服务地址:端口号,例如 tls-cn-beijing.ivolces.com:9094,其中: 服务地址为当前地域下日志服务的服务入口。请根据地域和网络类型选择正确的服务入口,详细信息请参见服务地址。 端口号固定为 9094。 说明 hosts 中的服务地址部分无需指定 https://。 topic 20a50a35-304a-4c01-88d2-23349c30**** 配置为日志服务的日志主题 ID。 配置步骤日志服务支持自动生成 Kafka 协议上传日志数据的相关参数配置...

使用 SASL_SSL 接入点连接实例

消息队列 Kafka版支持通过 SSL 证书对消息进行鉴权和加密,保障数据传输过程的安全性,防止数据在网络传输过程中被截取或者窃听,相较于普通访问方式具备更高的安全性。目前支持客户端对服务端证书的单向认证。 前提条件已获取 SASL_SSL 接入点信息,包括连接地址和端口号。详细信息请参考查看接入点。 已创建 Topic。操作步骤请参考创建 Topic。 如果通过公网访问实例,建议实例绑定的 EIP 带宽上限大于预估的公网业务流量峰值。详...

查看接入点

专有网络 VPC 为 Kafka 实例构建隔离的、自主配置和管理的虚拟网络环境,消息可以采用 PLAINTEXT 协议在安全的网络通道不加密传输。通过 VPC 方式访问实例时,您需要在同一地域下的火山引擎云服务器 ECS 搭建开发环境,部署客户端,或通过云企业网等方式将不同地域下的 ECS 打通,实现网络互通。在 VPC 网络下,消息队列Kafka版提供默认接入点、SASL_SSL 接入点和 SASL_PLAINTEXT 接入点供您选择。 默认接入点无需身份认证,配置接入点...

创建资源

本文将为您介绍消息队列 Kafka版控制台创建 Kafka 实例和 Topic 的操作步骤。 准备工作已开通消息队列 Kafka版,并进行了相关环境准备。创建的 Kafka 实例运行于私有网络中,在创建前确保已存在可用的私有网络和子网... Kafka 实例会提供 SASL 接入点,通过 SASL 用户名及密码鉴权后才能通过此接入点登录 Kafka 实例。 说明 通过默认接入点,不使用 SASL 用户名和密码访问实例,可以忽略本步骤。 创建实例时已同步创建了 SASL/PLAIN 类型...

特惠活动

企业直播体验福利包

20G存储+3000分钟时长,乐享1个月
0.00/0.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

产品体验

体验中心

云服务器特惠

云服务器
云服务器ECS新人特惠
立即抢购

白皮书

数据智能知识图谱
火山引擎数智化平台基于字节跳动数据平台,历时9年,基于多元、丰富场景下的数智实战经验打造而成
立即获取

最新活动

爆款1核2G共享型服务器

首年60元,每月仅需5元,限量秒杀
立即抢购

火山引擎增长体验专区

丰富能力激励企业快速增长
查看详情

数据智能VeDI

易用的高性能大数据产品家族
了解详情

一键开启云上增长新空间

立即咨询