www.3112.net > 多个topiC怎么设置kAFkAspout jAvA例子

多个topiC怎么设置kAFkAspout jAvA例子

public class j { static int add(int a,int b){ int s; s=a+b; return s; } public static void main(String args[]){ int i=1,j=2; int t; t=add(i,j); System.out.println("1+2=几?"); System.out.println("当然是:"+t); } }

public class j { static int add(int a,int b){ int s; s=a+b; return s; } public static void main(String args[]){ int i=1,j=2; int t; t=add(i,j); System.out.println("1+2=几?"); System.out.println("当然是:"+t); } }

已经消费了数据,但是offset没提交。 原因1:强行kill线程,导致消费后的数据,offset没有提交。

网站地图

All rights reserved Powered by www.3112.net

copyright ©right 2010-2021。
www.3112.net内容来自网络,如有侵犯请联系客服。zhit325@qq.com