在nginxconf里面配置上类似以下配置文件：
stream {
upstream dack{
server 127001:9092;
server 127001:9093;
server 127001:9094;
}
server{
listen 9091;
proxy_pass dack;
}
}
注意：stream级别和>
服务器鼎峰华仔告诉你：
以下为服务器常用端口列表：
端口服务说明
21FTPFTP服务所开放的端口，用于上传、下载文件。
22SSHSSH端口，用于通过命令行模式远程连接Linux服务器或vps。23TelnetTelnet端口，用于Telnet远程登录服务器。
25SMTPSMTP服务所开放的端口，用于发送邮件。
80>
110POP3用于POP3协议，POP3是电子邮件收发的协议。
143IMAP用于IMAP（InternetMessageAccessProtocol）协议，IMAP是用于电子邮件的接收的协议。
443>
1433SQLServerSQLServer的TCP端口，用于供SQLServer对外提供服务。
1434SQLServerSQLServer的UDP端口，用于返回SQLServer使用了哪个TCP/IP端口。
1521OracleOracle通信端口，服务器上部署了OracleSQL需要放行的端口。3306MySQLMySQL数据库对外提供服务的端口。
3389WindowsServerRemoteDesktopServicesWindowsServerRemoteDesktopServices（远程桌面服务）端口，可以通过这个端口远程连接服务器
8080代理端口同80端口一样，8080端口常用于>
137、138、139NetBIOS协议
137、138为UDP端口，通过网上邻居传输文件时使用的端口。
139通过这个端口进入的连接试图获得NetBIOS/SMB服务。
NetBIOS协议常被用于Windows文件、打印机共享和Samba。
为了安全考虑，建议客户机将防火墙打开，只需将常用端口添加到防火墙例外或入站规则。比如网站管理员一般仅开放：80、22、21、3306、1433等端口
S-eye是一个用于视频流传输和共享的开源平台，支持多种协议，包括> 在kafka的 config 目录下找到 serverproperties 配置文件
把 listeners 和 advertisedlisteners 两处配置的注释去掉，可以根据需要配置连接的服务器 外网IP 和 端口号 ，我这里演示选择的是本地 localhost 和默认端口 9092
KafkaTemplate 这个类包装了个生产者 Producer ，来提供方便的发送数据到 kafka 的主题 topic 里面。
send() 方法的源码， KafkaTemplate 类中还重载了很多 send() 方法，有需要可以看看源码
通过 KafkaTemplate 模板类发送数据。
kafkaTemplatesend(String topic, K key, V data) ,第一个入参是主题，第二个入参是发送的对象，第三个入参是发送的数据。通过 @KafkaListener 注解配置用户监听 topics
bootstrap-servers ：kafka服务器地址(可以多个)
consumergroup-id :指定一个默认的组名
不指定的话会报
1 earliest ：当各分区下有已提交的 offset 时，从提交的 offset 开始消费；无提交的 offset 时，从头开始消费
2 latest ：当各分区下有已提交的 offset 时，从提交的 offset 开始消费；无提交的 offset 时，消费新产生的该分区下的数据
3 none ： topic 各分区都存在已提交的 offset 时，从 offset 后开始消费；只要有一个分区不存在已提交的 offset ，则抛出异常
这个属性也是必须配置的，不然也是会报错的
在使用Kafka发送接收消息时，生产者 producer 端需要序列化，消费者 consumer 端需要反序列化，由于网络传输过来的是 byte[] ，只有反序列化后才能得到生产者发送的真实的消息内容。这样消息才能进行网络传输
consumerkey-deserializer 和 consumervalue-deserializer 是消费者 key/value 反序列化
producerkey-deserializer 和 producervalue-deserializer 是生产者 key/value 序列化
StringDeserializer 是内置的字符串反序列化方式
StringSerializer 是内置的字符串序列化方式
在 orgapachekafkacommonserialization 源码包中还提供了多种类型的序列化和反序列化方式
要自定义序列化方式，需要实现接口 Serializer
要自定义反序列化方式，需要实现接口 Deserializer
详细可以参考
>/
Kafka服务器连接参数
Created by gerry on 12/21
/
public class KafkaBrokerInfo {
// 主机名
public final String brokerHost;
// 端口号
public final int brokerPort;
/
构造方法
@param brokerHost Kafka服务器主机或者IP地址
@param brokerPort 端口号
/
public KafkaBrokerInfo(String brokerHost, int brokerPort) {
thisbrokerHost = brokerHost;
thisbrokerPort = brokerPort;
}
/
构造方法， 使用默认端口号9092进行构造
@param brokerHost
/
public KafkaBrokerInfo(String brokerHost) {
this(brokerHost, 9092);
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）