我正在使用KafkaConsumer来消费来自Kafka服务器（主题）的消息。 它适用于在启动消费者代码之前创建的主题… 但问题是，如果动态创建的主题（我的意思是说消费者代码开始之后），它将无法工作，但API表示它将支持动态主题创建..这是您的参考链接.. 使用的Kafka版本：0.9.0.1 https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html 这是JAVA代码…… Properties props = new Properties(); props.put(“bootstrap.servers”, “localhost:9092”); props.put(“group.id”, “test”); props.put(“enable.auto.commit”, “false”); props.put(“auto.commit.interval.ms”, “1000”); props.put(“session.timeout.ms”, “30000”); props.put(“key.deserializer”,”org.apache.kafka.common.serialization.StringDeserializer”); props.put(“value.deserializer”,”org.apache.kafka.common.serialization.StringDeserializer”); KafkaConsumer consumer = new KafkaConsumer(props); Pattern r = Pattern.compile(“siddu(\\d)*”); consumer.subscribe(r, new HandleRebalance()); try { while(true) { ConsumerRecords records = consumer.poll(Long.MAX_VALUE); for (TopicPartition partition : records.partitions()) { List<ConsumerRecord> partitionRecords = records.records(partition); for (ConsumerRecord […]

SharePoint新手。 我正在尝试使用Java的CopyIntoItems Web服务方法将文档上传到SharePoint，但继续获得400 Bad Request。 我使用Java的wsimport从.wsdl文件生成类文件。 这是我生成的类的Java代码。 public static void createDocument(CopySoap port) { String url = SoapPortProvider.spSiteUrl + “/Shared Documents/Temp Folder/test.txt”; String sourceUrl = “http://null”; byte[] content = IoUtil.getBytes(new File(“C:/CopyFile/READ-ME.txt”)); FieldInformation descInfo = new FieldInformation (); descInfo.setDisplayName(“Test Doc”); descInfo.setType(FieldType.TEXT); descInfo.setValue(“Test uploaded file”); DestinationUrlCollection urls = new DestinationUrlCollection(); urls.getString().add(url); FieldInformationCollection infos = new FieldInformationCollection (); infos.getFieldInformation().add(descInfo); […]

在我的Spring Web MVC应用程序中，我在@Controller有一堆方法，它们使用@RequestParam接受Date作为输入参数。 没有定义任何自定义数据绑定器或属性编辑器（我承认我仍然不清楚这两者之间的区别），默认支持哪些日期格式？ 例如，我注意到像’11 / 12/2012 16:50 PM’之类的工作正常，但像’1352815200000’这样的普通milis值被拒绝了。 编辑：我得到的具体exception是：“无法将类型’java.lang.String’的值转换为必需的类型’java.util.Date’;嵌套exception是java.lang.IllegalStateException：无法转换类型的值[java .lang.String]到必需的类型[java.util.Date]：找不到匹配的编辑器或转换策略“

我使用触发器设置所有表的PK列值，所以我不对Java中的ID做任何操作，但我需要插入后的ID。 我怎样才能获得身份证？ stat.execute(“INSERT INTO TPROJECT_PROCESS_GROUP(NPROJECT_ID,VDESCRIPTION) ” + “VALUES(” + “‘” + projectID + “‘,” + “‘” + description + “‘” + “”); 编辑：嗨再次我读了这个问题，现在我得到了一个例外，比如’不支持的操作’（我翻译自我的母语，确切的英文forms可能会有所不同）。 我想这是关于oracle对GetGeneratedKeys的支持？ 你对此有所了解吗？ 解决方案：正如关于callablestatements的书中所提到的，该语句可用于执行存储过程和函数。 与PreparedStatement不同，大多数数据库不会对调用执行任何准备，因为它是一个如此简单的命令。 CallableStatement实例可用于返回存储过程或函数的对象，更准确地返回。 OracleConnection conn = null; //OraclePreparedStatement pstat = null; OracleCallableStatement cstat = null; String sql = “BEGIN INSERT INTO TPROJECT P (VPROJECT_TITLE,VPROJECT_DESC) VALUES(?,?) RETURNING P.NPROJECT_ID INTO ?; END;”; […]

我有一个Play框架2应用程序，可以接收数据并通过WebSockets将其发送到多个客户端。 我使用Akka actor来处理WebSockets，就像在本文档中一样 。 我还有一个WebSocketRouter类，它扩展了UntypedActor并包含路由逻辑（决定哪些客户端传递系统接收的数据）。 我知道我可以使用Akka的Routerfunction，但对我来说这不是问题。 问题是我必须存储所有活动客户端的列表。 现在我将它存储在WebSocketRouter类的静态列表中。 这是编写概念validation原型的最快方法，但它不是线程安全的，似乎不是“Akka方式”。 下面是一个简化的代码示例： WebSocketController： //This controller handles the creation of WebSockets. public class WebSocketController extends Controller { public static WebSocket index() { return WebSocket.withActor(new F.Function() { public Props apply(ActorRef out) throws Throwable { return MessageSender.props(out); } }); } } MessageSender： //Hold a reference to the auto-created Actor that […]

我正在尝试在服务器启动之前注册一个新的数据源，但是我正在查找执行的查找 javax.naming.NameNotFoundException：名称[jdbc / db]未绑定在此Context中。 无法找到[jdbc]。 这是我启动tomcat的方式： Tomcat tomcat = new Tomcat(); //… ContextResource resource = new ContextResource(); resource.setName(“jdbc/db”); resource.setAuth(“Container”); resource.setType(“javax.sql.DataSource”); resource.setScope(“Sharable”); resource.setProperty(“driverClassName”, “org.hsqldb.jdbc.JDBCDriver”); resource.setProperty(“url”, “jdbc:hsqldb:hsql://localhost:1234/mydb1”); tomcat.getServer().getGlobalNamingResources().addResource(resource); tomcat.start(); tomcat.getServer().await(); 查找： Connection conn = null; try { Context initContext = new InitialContext(); Context envContext = (Context) initContext.lookup(“java:/comp/env”); DataSource ds = (DataSource) envContext.lookup(“jdbc/db”); conn = ds.getConnection(); conn.createStatement()…. } […]

在开发Java Swing GUI时，扩展JFrame总是一个坏主意吗？ 那么JPanel或其他JComponents呢？ 还有什么让它变坏？

只是玩Javareflection，我想我大部分时间都在掌握它。 我从这个问题/答案中了解到，在大多数情况下，我仅限于静态变量。 如果我有一个类的实例，我可以访问非静态变量，这确实有意义，我得到了那么多。 说我有以下两个类： public class A { private static int _staticInt; public static void main(String[] args) { B instanceOfB = new B(); } } public class B { private int _nonStaticInt; public Game() {} } 我理解如何访问_staticInt ，这不是问题。 我的理解是我可以以相同的方式获取_nonStaticInt的Field （即Field f = B.class.getDeclaredField(“_nonStaticInt”); ）。 从其他研究（javadocs， _nonStaticInt等）我收集到我需要B的实例才能获得_nonStaticInt的值。 所以我的问题; 由于main是静态的，是否可以访问instanceOfB以访问_nonStaticInt的值？ 我不认为这是可能的，但我认为在放弃这个想法之前，最好先咨询比我更了解的人。

当我动态创建文本和标签框时，它应该采用“Textbox：Labelbox”的格式，然后当我再次点击添加按钮时，相同的模式应该在下一行重复，依此类推……我应该使用哪种布局以及如何使用？ 这是我使用的代码 if(field_name.getText().equals(“”)){ error.setForeground(Color.red); error.setText(“Enter the Field name first”); } else { JLabel l = new JLabel(field_name.getText(), JLabel.RIGHT); JTextField textField = new JTextField(); Dimension dim = new Dimension(20,30); textField.setPreferredSize(dim); field_layer.add(l); field_layer.add(textField); SpringUtilities.makeCompactGrid(field_layer, numPairs, 2, //rows, cols 6, 6, //initX, initY 6, 6); //xPad, yPad numPairs++; field_layer.invalidate(); this.pack(); }

是否有一些hack为java.sql.Connection创建一个包装器，它与JDBC 3和4一起工作（Sun为JDBC 4的接口添加了几个方法和新类型）， 而不需要在编译时修补源代码？ 我的用例是我需要生成一个适用于Java 5和6的库，我真的想避免创建它的两个版本。