小编gau*_*rav的帖子

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); 
producer.send(keyedMessage);

目前,我发送的消息没有任何密钥作为键控消息的一部分,它仍然可以使用delete.retention.ms吗？我是否需要发送密钥作为邮件的一部分？将密钥作为消息的一部分是否合适？

我们可以为XML中提到的相同bean id重复名称吗？如果没有,那么我们如何在Spring中覆盖bean呢？

如何在DB2中的sql中获取逗号分隔列值的内置函数,例如,如果存在具有此策略ID的列,并且它具有3行具有相同id但在三行中具有三个不同角色,那么它应该在一行中检索行排"3,4,5"

例如

ID   | Role
------------
4555 | 2
4555 | 3
4555 | 4

DB2 SQLDB2中的输出在一行中

我们应该destroy()从Servlet中的init()和service()方法中调用该方法吗？我在博客中得到了许多令人困惑的答案.

据我所知,当我们destroy()从init()它调用方法时应调用并销毁servlet,如果我们要覆盖destroy()我们的servlet中.然后servlet将被销毁.

以上理解是对的吗？

我正在使用hortonwork Sandbox for kafka服务器尝试使用java代码连接eclipse中的kafka.使用此配置连接到生产者以发送消息

metadata.broker.list=sandbox.hortonworks.com:45000
serializer.class=kafka.serializer.DefaultEncoder
zk.connect=sandbox.hortonworks.com:2181
request.required.acks=0
producer.type=sync

sandbox.hortonworks.com是我连接的沙箱名称

在kafka server.properties中,我更改了此配置

host.name=sandbox.hortonworks.com

advertised.host.name=System IP(on which my eclipse is running)
advertised.port=45000

也做了端口转发,

我能够从eclipse连接到kafka服务器但是在发送消息时获得异常异常"3次尝试后无法发送消息".

我试过将proto转换为java pojo.但得到了错误

[Stderr] Order.proto:12:18:预期"必需","可选"或"重复".[Stderr] Order.proto:12:21:预期的字段名称.

optional int32 orderID = 1; 
optional int32 quantity = 2;    
map<string,string> map_field = 4;
repeated string product = 3;

请帮助我需要改变什么.我搜索谷歌protobuf开发者网站 https://developers.google.com/protocol-buffers/docs/proto#maps 它说地图字段不能重复,可选或必需

请帮我解决这个问题.

我在 0.8.1 版本的 kafka 中创建主题时配置了这个属性 delete.retention.ms。这个属性有什么作用？是否会在 kafka 的特定时间间隔后删除消息。

我必须从数据库中获取500K行并将该数据写入文件中,Means执行I/O操作.我已经完成了两个步骤.

1. 将每一行逐个写入文件.
2. 制作那些行的块.在StringBuffer中添加这些行然后打印它们.这个会更好但是有没有什么方法可以让File I/O自己创建缓冲区而不使用StringBuffer.因为这个字符串缓冲区需要更多时间(内部使用Arrays.copyOf)

请建议我这个请找到附带的代码

public void fetchDataWithChunkSpace(Connection con)throws Exception
        {
            String query ="select * from lis.testxml  ";
            long startTime=new Date().getMinutes();
            PreparedStatement stmt = con.prepareStatement(query);
            ResultSet rs = stmt.executeQuery();
            PrintWriter pw = new PrintWriter(new File("c:\\test_chunkSpace.xml"));
            pw.write("<?xml version='1.0' encoding='UTF-8'?>");
            StringBuffer sb = new StringBuffer();
            String t=null; 
            long count =0;
            while(rs.next())
            {   count++;
                t = rs.getString("xmltest");
                sb = sb.append(t);
                if(count%100==0)
                {
                 pw.write(sb.toString());
                 sb = new StringBuffer();
                 System.out.println(count);
                }
            }
            pw.write("\n");
            pw.write("</EndTag>");
            pw.close();
            stmt.close();
            con.close();
            long endTime=new Date().getMinutes();
            System.out.println("chunkSpace  ---> " + (endTime-startTime)); …

public final class ObjectsJava 7中有一个扩展java.lang.Object基类的东西.

这默认是基类,还是我们需要在"Objects"类上调用方法并调用相应的方法？