根据你所述,当项目起来时SpringBoot会自动创建topic1,topic2,topic3三个Topic(例子中),实际上我的Copy下来的项目启动直接报错:
Caused by: java.lang.IllegalStateException: Topic(s) [topic2, topic3] is/are not present and missingTopicsFatal is true at org.springframework.kafka.listener.AbstractMessageListenerContainer.checkTopics(AbstractMessageListenerContainer.java:351) ~[spring-kafka-2.3.0.RC1.jar:2.3.0.RC1] at org.springframework.kafka.listener.ConcurrentMessageListenerContainer.doStart(ConcurrentMessageListenerContainer.java:136) ~[spring-kafka-2.3.0.RC1.jar:2.3.0.RC1] at org.springframework.kafka.listener.AbstractMessageListenerContainer.start(AbstractMessageListenerContainer.java:308) ~[spring-kafka-2.3.0.RC1.jar:2.3.0.RC1] at org.springframework.kafka.config.KafkaListenerEndpointRegistry.startIfNecessary(KafkaListenerEndpointRegistry.java:309) ~[spring-kafka-2.3.0.RC1.jar:2.3.0.RC1] at org.springframework.kafka.config.KafkaListenerEndpointRegistry.start(KafkaListenerEndpointRegistry.java:256) ~[spring-kafka-2.3.0.RC1.jar:2.3.0.RC1] at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:182) ~[spring-context-5.2.0.BUILD-SNAPSHOT.jar:5.2.0.BUILD-SNAPSHOT] ... 14 common frames omitted
我手动创建了topic1事实证明才是可行的;SpringBoot会在何时创建.yml中定义的topic array?i lost something configurations?

麻烦提供一下springboot整合spark示例的链接，谢谢

[ERROR] Failed to execute goal org.springframework.boot:spring-boot-maven-plugin:1.3.2.RELEASE:repackage (default) on project quick-spark: Execution default of goal org.springframework.boot:spring-boot-maven-plugin:1.3.2.RELEASE:repackage failed: Unable to find a single main class from the following candidates [spark.Application, spark.textmatch.SimHash, com.spark.scala.LinearRegression, com.spark.textmatch.TextMatch, spark.test.java.EmailFilter, spark.test.java.Test, spark.test.java.Word2VecTest] -> [Help 1]

大佬，小白想请教rabbitmq的延迟队列如何实现，你的rabbitmq模块中貌似还没加入呢

有兴趣一起研究GraphQL 吗？

mvn package docker:build
打包失败，解决方法：

             <plugin>
                <groupId>com.spotify</groupId>
                <artifactId>docker-maven-plugin</artifactId>
                <version>0.4.13</version>
                <configuration>
                    <imageName>${docker.image.prefix}/${project.artifactId}</imageName>
                    <dockerDirectory>src/main/docker</dockerDirectory>
                    <resources>
                        <resource>
                            <targetPath>/</targetPath>
                            <directory>${project.build.directory}</directory>
                            <include>${project.build.finalName}.jar</include>
                        </resource>
                    </resources>
                </configuration>
            </plugin>

docker-maven-plugin 从0.4.3更新到0.4.13

你好！ 今天在使用您的代码，在启动时出现了如下问题（spark分支）：2017-05-19 20:11:51,986 WARN AnnotationConfigEmbeddedWebApplicationContext:546 - Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'applicationConfig': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private java.lang.String com.spark.config.ApplicationConfig.appName; nested exception is java.lang.IllegalArgumentException: Could not resolve placeholder 'spark.app.name' in string value "${spark.app.name}"
2017-05-19 20:11:51,996 INFO StandardService:180 - Stopping service Tomcat
2017-05-19 20:11:52,020 ERROR SpringApplication:827 - Application startup failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'applicationConfig': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private java.lang.String com.spark.config.ApplicationConfig.appName; nested exception is java.lang.IllegalArgumentException: Could not resolve placeholder 'spark.app.name' in string value "${spark.app.name}"
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessPropertyValues(AutowiredAnnotationBeanPostProcessor.java:334)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1214)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:543)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:482)
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
抱歉我对java系的东西不太熟悉 能帮我看下这是什么问题吗

spring-boot-quick/quick-activemq2/src/main/java/com/active2/config/ActiveMQConfig.java
#56 57行缩进两次tap （手动狗头-_-!）

按照楼主的文档,已经可以正常发送消息和消费消息.
但是在 kafka-manager上看不到以下数据

请问您这边是否也遇到同样的问题?

GraphQL的话 数据源使用MySQL 是不是构建较多的SQL
那和restful就没任何变化了

嗨，在博客站看到你的springboot和spark示例，
请问如何实现以下需求呢?

在windows环境开发，linux虚拟机装spark, 如何在windows的springboot开发项目中，在一个junit test中远程调用linux中的spark执行任务呢?

一个人走的很快，但是一群人可以走的很远~~~

大家如果有感兴趣的模块可以在这里提一提，我尽可能的添加进去~~~

是因为性能原因吗？

可以在存图片的时候前面加mkdirs