「java连接kafka」java连接kafka失败

今天给各位分享java连接kafka的知识，其中也会对java连接kafka失败进行解释，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

本文目录一览：

• 1、kafka集群测试正常，但是Java连接kafka出现异常，急求大神解答！！！！！！！！！！！
• 2、怎么使用java连接kafka
• 3、kafka java 通过url连接服务器

kafka集群测试正常，但是Java连接kafka出现异常，急求大神解答！！！！！！！！！！！

首先你在链接时候检查是否代码里的IP 和端口是不是对的，端口是broker 端口，默认9092 ；

其次查看代码是生产者，看Kafka 集群里这个主题是否存在（如果不存在，默认是配置可以自动创建，看是非将该配置修改）；然后检测防火墙，相应端口是否开放（防火墙直接关也可以）；检测 server.properties 文件的 listeners 是否配置，若没有将其配置好

怎么使用java连接kafka

把你要传递的数据转换成json字符串返回接口，然后手机端调用接口就可以获取到你要传递是值了

kafka java 通过url连接服务器

可以连接到一个网络服务器并且能够从这个服务器下载指定的URL，程序中直接使用HTTP协议。程序将定义一个输出流，下载的URL的内容将来被写入这个流，通过socket来获得输入和输出流：

view sourceprint?

01 import java.io.*;

02 import java.net.*;

03 public class HttpClient {

04 public static void main(String[] args) {

05 try {

06 // Demo参数:

07 if ((args.length != 1) (args.length != 2))

08 throw new IllegalArgumentException("Wrong number of args");

09 //定义输出流，下载的URL内容被写入这个流

10 OutputStream to_file;

11 if (args.length == 2) to_file = new FileOutputStream(args[1]);

12 else to_file = System.out;

13 //使用URL类来把用户指定的URL解析成几个部分

14 URL url = new URL(args[0]);

15 String protocol = url.getProtocol();

16 if (!protocol.equals("http")) // 检验是否满足支持的协议

17 throw new IllegalArgumentException("Must use 'http:' protocol");

18 String host = url.getHost();

19 int port = url.getPort();

20 if (port == -1) port = 80; //如果没有指定端口，用默认端口

21 String filename = url.getFile();

22 // 打开一个连接到指定主机和端口的网络socket连接

23 Socket socket = new Socket(host, port);

24 // 通过socket来获得输入和输出流

25 InputStream from_server = socket.getInputStream();

26 PrintWriter to_server = new PrintWriter(socket.getOutputStream());

27

28 // 发送HTTP GET命令给网络服务器，指定要下载的文件

29 // 使用了一个老版本非常简单的HTTP协议

30 to_server.print("GET " + filename + "\n\n");

31 to_server.flush(); // 立即发送

32 // 现在读取服务器的响应，把接收到的内容写入文件

33 byte[] buffer = new byte[4096];

34 int bytes_read;

35 while((bytes_read = from_server.read(buffer)) != -1)

36 to_file.write(buffer, 0, bytes_read);

37 // 当服务器关闭连接时，也关闭stuff

38 socket.close();

39 to_file.close();

40 }

41 catch (Exception e) { // 发布错误

42 System.err.println(e);

43 System.err.println("Usage: java HttpClient URL [filename]");

44 }

45 }

46 }

java连接kafka的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于java连接kafka失败、java连接kafka的信息别忘了在本站进行查找喔。