René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Kafka Consumer \u003e KafkaAutoConfiguration seems not to work [axon 3.3.3 + spring boot 2.0.4.RELEASE]","articleBody":"I have defined no additional configuration and the application doesn't start by just defining the consumer-group-id as defined the Axon documentation.\r\n\r\nDependencies:\r\n```\r\n    implementation('org.axonframework:axon-spring-boot-starter:3.3.3')\r\n    implementation('org.apache.kafka:kafka-clients:2.0.0')\r\n    implementation('org.axonframework:axon-kafka:3.3.3')\r\n    + spring-boot 2.0.4.RELEASE\r\n```\r\n\r\nHere is the configuration i have defined in my application.yml\r\n\r\n```\r\naxon:\r\n  kafka:\r\n    default-topic: \"my-topic\"\r\n    bootstrap-servers: \"bootstrap.kafka.svc.cluster.local:9092\"\r\n    consumer:\r\n      group-id: \"query-consumer\"\r\n      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer\r\n      value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer\r\n```\r\nHere are the corresponding starting logs:\r\n\r\n```\r\n\r\n***************************\r\nAPPLICATION FAILED TO START\r\n***************************\r\n\r\nDescription:\r\n\r\nParameter 0 of method kafkaMessageSource in org.axonframework.boot.autoconfig.KafkaAutoConfiguration required a bean of type 'org.axonframework.kafka.eventhandling.consumer.Fetcher' that could not be found.\r\n\t- Bean method 'kafkaFetcher' in 'KafkaAutoConfiguration' not loaded because @ConditionalOnBean (types: org.axonframework.kafka.eventhandling.consumer.ConsumerFactory,org.axonframework.kafka.eventhandling.KafkaMessageConverter; SearchStrategy: all) did not find any beans of type org.axonframework.kafka.eventhandling.KafkaMessageConverter\r\n\r\n\r\nAction:\r\n\r\nConsider revisiting the entries above or defining a bean of type 'org.axonframework.kafka.eventhandling.consumer.Fetcher' in your configuration.\r\n\r\n2018-08-13 18:42:36,923 ERROR :  gid: trace= span= [main] o.s.b.d.LoggingFailureAnalysisReporter \r\n\r\n***************************\r\nAPPLICATION FAILED TO START\r\n***************************\r\n\r\nDescription:\r\n\r\nParameter 0 of method kafkaMessageSource in org.axonframework.boot.autoconfig.KafkaAutoConfiguration required a bean of type 'org.axonframework.kafka.eventhandling.consumer.Fetcher' that could not be found.\r\n\t- Bean method 'kafkaFetcher' in 'KafkaAutoConfiguration' not loaded because @ConditionalOnBean (types: org.axonframework.kafka.eventhandling.consumer.ConsumerFactory,org.axonframework.kafka.eventhandling.KafkaMessageConverter; SearchStrategy: all) did not find any beans of type org.axonframework.kafka.eventhandling.KafkaMessageConverter\r\n```\r\n\r\nI could make the application start by redefining this in a class annotated with @Configuration:\r\n```\r\n@ConditionalOnMissingBean\r\n    @Bean\r\n    public KafkaMessageConverter\u003cString, byte[]\u003e kafkaMessageConverter(\r\n            @Qualifier(\"eventSerializer\") Serializer eventSerializer) {\r\n        return new DefaultKafkaMessageConverter(eventSerializer);\r\n    }\r\n``` \r\n\r\nBut still nothing is consumed from the Kafka topic (no tracking event processor is started).\r\n\r\nI then tried to define to add this in addition to try to register manually an event processor for my KafkaMessageSource but still without any success.\r\n\r\n```\r\n    @Autowired\r\n    public void trackingEventProcessor(\r\n            @SuppressWarnings(\"SpringJavaInjectionPointsAutowiringInspection\") EventProcessingConfiguration eventProcessingConfiguration,\r\n            KafkaMessageSource kafkaMessageSource) {\r\n        eventProcessingConfiguration.registerTrackingEventProcessorUsingSource(\"kafka-tracking-event-processor\", configuration -\u003e kafkaMessageSource);\r\n    }\r\n\r\n    @Bean\r\n    public EventStorageEngine eventStorageEngine(){\r\n        return new InMemoryEventStorageEngine();\r\n    }\r\n\r\n    @Bean\r\n    public TokenStore tokenSTore(){\r\n        return new InMemoryTokenStore();\r\n    }\r\n```\r\nAny clue on how to configure this properly? ","author":{"url":"https://github.com/ghilainm","@type":"Person","name":"ghilainm"},"datePublished":"2018-08-13T16:48:33.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":4},"url":"https://github.com/82/ReferenceGuide/issues/82"}