ConsumersCount is amount of kafka.consumer.Consumer instances.
consumerStreams is amount of kafka.consumer.KafkaStream instances.
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
http://ingest.tips/2014/10/12/kafka-high-level-consumer-frequently-missing-pieces/
--
View
I'm thinking to stop execution in case of exception, but I do want to perform
some logging in finally block. The .stop() definition looks like does what I
need but it stops finally definition as well.
https://github.com/vasilievip/camel-spring-boot/blob/master/src/main/java/cameltest
Ok, I tested out the change and it works like a charm in unit test, but in
main class itself I think there is still some issue.
Lets take as an example Boot1.java from my example project, if I do this:
@Configuration
@EnableAutoConfiguration
@Import({*CamelAutoConfiguration.class,*
Oops, my bad, the issue is that spring-boot-autoconfigure dependency is only
available for test scope
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758668.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Yes, everything works fine. Thank you!
Looks like for the main, optional flag makes some classpath magic not
working :)
dependency
groupIdorg.springframework.boot/groupId
artifactIdspring-boot-starter/artifactId
version${spring-boot.version}/version
See attached:
camel-spring-boot-example.zip
http://camel.465427.n5.nabble.com/file/n5758700/camel-spring-boot-example.zip
- Run Boot1 and take a look at output
- Run Boot2 and take a look at output
--
View this message in context:
Thanks!
Will try latest changes and let you know the results.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-boot-autowiring-issue-tp5758543p5758592.html
Sent from the Camel - Users mailing list archive at Nabble.com.
There is still no sources for latest build only for previous one. I guess
this has something to do with set of profiles enabled for no tests build
and all tests build.
--
View this message in context:
I see strange behavior when trying to use camel boot.
When config class for camel creates beans (RoutesBuilder's) it does not see
autowired fields - they are not initialized, but in @PostConstruct method
they are getting initialized. When I add additional config file (see
Boot2.java in my
https://repository.apache.org/content/repositories/snapshots/org/apache/camel/camel-core/2.15-SNAPSHOT/
If you take a look at latest snapshot build - it does not contain sources,
sources as published for the previous snapshot, but maven sees that there
newest build and ignores sources.
Something
10 matches
Mail list logo