spring boot kafka consumer – 如何从spring boot中正确使用kafka消息

我正在开发一个弹簧启动应用程序,它假设使用kafka消息。 我有一个奇怪的结果:当我使用kafka-console-producer.sh发送消息时,我的消费者只检测并打印另一条消息。 例如 – 在kafka控制台生产者中,我输入“one” – > Enter – >“two” – > Enter – >“three” – > Enter。 在我的春季靴子消费者中,我只会看到“两个”,“四个”等… 我的ConsumeConfigFactory.java: import java.util.Properties; import javax.annotation.PostConstruct; import kafka.consumer.ConsumerConfig; import org.springframework.stereotype.Component; @Component public class ConsumerConfigFactory { private static final String ZK_CONNECT = “10.211.55.2:2181”; private ConsumerConfig consumerConfig; @PostConstruct private void createConsumerConfig() { Properties props = new Properties(); props.put(“zookeeper.connect”, ZK_CONNECT); […]

由于SSLException,无法连接到SQLServer

从昨天开始,我无法从JBoss EAP 6.2连接到本地开发机器上的MicroSoft SQLServer(v11.1.3000.0)。 SQLServer现在想要使用SSL进行连接。 我得到以下exception: Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: The driver could not establish a secure connection to SQL Server by using Secure Sockets Layer (SSL) encryption. Error: “java.lang.RuntimeException: Could not generate DH keypair”. ClientConnectionId:da0dbbf4-33a0-45ac-9885-fa1e31c47c6e at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:1667) at com.microsoft.sqlserver.jdbc.TDSChannel.enableSSL(IOBuffer.java:1668) at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(SQLServerConnection.java:1323) at com.microsoft.sqlserver.jdbc.SQLServerConnection.login(SQLServerConnection.java:991) at com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(SQLServerConnection.java:827) at com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(SQLServerDriver.java:1012) at org.jboss.jca.adapters.jdbc.local.LocalManagedConnectionFactory.getLocalManagedConnection(LocalManagedConnectionFactory.java:260) … 28 more Caused by: javax.net.ssl.SSLException: […]

尝试删除文件时AccessControlException

我们有一个使用log4j进行日志记录的java Web服务应用程序。 当log4j尝试删除其滚动日志文件时,会抛出exception Exception:java.security.AccessControlException: access denied (java.io.FilePermission /var/opt/SUNWappserver/domains/domain1/ applications/j2ee-modules/ourwebservice/WEB-INF/logs/IMWrapper.log.10 delete) 当我们在目录中执行ls ,服务帐户有权读取和写入文件和目录。 从一些初始谷歌搜索看来,我们可能不得不更改security.policy文件以允许服务删除文件。 有什么建议么?

Java Web App上传和加载图像

所以,我正在使用Spring Framework开发简单的Web应用程序。 应用程序用户可以上传图像。 存储/加载图像的最佳做法是什么? 我在某个论坛找到了解决方案,有人建议将文件存储到user.dir目录。 好的,我也这样做。 当用户上传图像时,我将图像存储到user.dir目录。 现在,我有一个问题:如何将图像从user.dir目录加载到页面?

OSGi:缺少要求osgi.wiring.package

我写了一个包含5个模块的项目。 我使用maven在intellij IDEA中创建它们,然后为所有模块添加“OSGi”框架支持。 我使用maven-bundle-plugin来配置export-package和import-package。 但是当我运行它时,总会出现错误: org.osgi.framework.BundleException: Unable to resolve org.gxkl.launcher [12] (R 12.0): missing requirement [org.gxkl.launcher [12](R 12.0)] osgi.wiring.package; (osgi.wiring.package=org.gxkl.server). 启动程序模块包含Bundle-Activator,org.gxkl.server包位于服务模块中。 我使用类似的pom来配置模块,但只有服务模块出错。 启动器中的pom文件如下: ${parent.artifactId} ${parent.groupId} ${parent.version} ${model.version} launcher bundle … ${project.groupId} service ${project.version} … org.apache.maven.plugins maven-source-plugin org.apache.maven.plugins maven-compiler-plugin org.apache.felix maven-bundle-plugin true org.gxkl.Starter org.gxkl … org.gxkl.server 服务中的pom文件如下: ${parent.artifactId} ${parent.groupId} ${parent.version} ${model.version} service bundle … … org.apache.maven.plugins […]

是否有任何方法可以在servlet中获取jetty上的所有有效会话密钥值?

我有一个带有两个不同servlet的jetty容器,然后调用A和B.在特殊情况下,qr代码代码出现在servlet A中(用户已经登录并正在使用他的桌面)和用户使用他的移动设备阅读此qr代码并将其重定向到其移动设备上的servlet B. 这里的问题是我无法保持他的会话。 QR码带来用户会话密钥,但我无法validation此会话是否有效。 我想知道是否有任何特殊的方法来请求jetty上的有效会话密钥,因为两个servlet都在同一个服务器上。

为什么以及在哪里调用setLocale

我需要为我的应用程序创建一个SQLite DB。 我需要以几种欧洲语言存储文本,因此会有大量的重音字符和其他奇怪的标记。 我正在扩展SQLiteOpenHelper 。 检查.db文件我注意到有一个名为android_metadata的额外表。 有一个名为locale列,默认情况下在我的模拟器中设置为“en_US”。 我已经开发了开发人员指南中的SQLite部分,以及在SO和Google中搜索过的SQLiteOpenHelper和SQLiteDatabase的javadocs,但我无处可找到将语言环境设置到数据库的正确位置,或者是否真的是必要的。 猜测它应该在DB创建时完成,我尝试在helper的onCreate方法中调用db.setLocale ,但是我得到了这个exception: BEGIN TRANSACTION failed setting locale FATAL EXCEPTION: Thread-9 android.database.sqlite.SQLiteException: cannot start a transaction within a transaction at android.database.sqlite.SQLiteDatabase.native_setLocale(Native Method) at android.database.sqlite.SQLiteDatabase.setLocale(SQLiteDatabase.java:1950) 这是我的方法的样子: public class MyOpenHelper extends SQLiteOpenHelper { @Override public void onCreate(SQLiteDatabase db) { db.setLocale(new Locale(“en”,”EN”)); … } … } 以下是我的问题: 我真的需要将语言环境设置为DB吗? 我真的不需要开箱即用的查询,因为我总是可以自己对结果进行排序。 我应该在哪里调用setLocale ?

保存新对象时,Hibernate未知实体错误

Student s = (Student) db.getByID(Student.class,1); s.setFirstName(“Preston”); db.saveOrUpdate(s); <–Successful save s = new Student(){{setFirstName("asdf");setLastName("asdf1");}}; s.setSchool((School) db.getByID(School.class, 1)); db.saveOrUpdate(s); <–Error occurs 线程“main”中的exceptionorg.hibernate.MappingException:未知实体:project.databaseio.TestClass $ 1 public void saveOrUpdate(Object object) { Transaction tx = sessionFactory.getCurrentSession().beginTransaction(); sessionFactory.getCurrentSession().saveOrUpdate(object); tx.commit(); } 堆栈跟踪 Exception in thread “main” org.hibernate.MappingException: Unknown entity: project.databaseio.TestClass$1 at org.hibernate.impl.SessionFactoryImpl.getEntityPersister(SessionFactoryImpl.java:548) at org.hibernate.impl.SessionImpl.getEntityPersister(SessionImpl.java:1338) at org.hibernate.engine.ForeignKeys.isTransient(ForeignKeys.java:180) at org.hibernate.event.def.AbstractSaveEventListener.getEntityState(AbstractSaveEventListener.java:487) at org.hibernate.event.def.DefaultSaveOrUpdateEventListener.performSaveOrUpdate(DefaultSaveOrUpdateEventListener.java:84) at org.hibernate.event.def.DefaultSaveOrUpdateEventListener.onSaveOrUpdate(DefaultSaveOrUpdateEventListener.java:70) […]

JBoss从JBoss AS 4.2 GA迁移到JBoss EAP 6.2

有没有人完成从JBoss AS 4.2 GA到JBoss EAP 6.2的迁移? JBoss EAP 6.2是否有网络和应用服务器..? 在JBoss AS 4.2 GA中有文件夹结构/ server / app和/ server / web,在JBoss EAP 6.2中根本没有服务器文件夹。 如何在JBoss EAP 6.2中部署Web和app中的服务? 通过系统迁移指南,由于模块类加载的更改,必须更改EAR或WAR的打包结构。 在JBoss AS 4.2中何处/如何查找系统依赖项,用户依赖项,本地资源和部署间依赖项。 提前致谢。

将Android应用程序连接到Google Cloud Endpoints时出错:无法找到课程

我已经使用Google Cloud Endpoints构建了一个API,我正在尝试连接到它编写Android应用程序。 我按照以下教程: https://developers.google.com/appengine/docs/java/endpoints/consume_android 所以,我在我的“src”文件夹中添加了jar的内容,我将列出的库复制到lib并添加了代码。 当我尝试启动应用程序时,它崩溃了以下错误: 02-26 12:19:52.874: E/dalvikvm(17558): Could not find class ‘com.google.api.services.utenteendpoint.Utenteendpoint$Builder’, referenced from method com.example.androidgcetest.MainActivity.onCreate 02-26 12:19:53.004: E/AndroidRuntime(17558): FATAL EXCEPTION: main 02-26 12:19:53.004: E/AndroidRuntime(17558): java.lang.NoClassDefFoundError: com.google.api.services.utenteendpoint.Utenteendpoint$Builder 02-26 12:19:53.004: E/AndroidRuntime(17558): at com.example.androidgcetest.MainActivity.onCreate(MainActivity.java:22) 02-26 12:19:53.004: E/AndroidRuntime(17558): at android.app.Activity.performCreate(Activity.java:4465) 02-26 12:19:53.004: E/AndroidRuntime(17558): at android.app.Instrumentation.callActivityOnCreate(Instrumentation.java:1049) 02-26 12:19:53.004: E/AndroidRuntime(17558): at android.app.ActivityThread.performLaunchActivity(ActivityThread.java:1931) 02-26 12:19:53.004: E/AndroidRuntime(17558): at android.app.ActivityThread.handleLaunchActivity(ActivityThread.java:1992) […]