doc-architect/doc-architect-core/src/main/java/com/docarchitect/core/scanner/impl/java/KafkaScanner.java [244:257]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        cu.findAll(ClassOrInterfaceDeclaration.class).forEach(classDecl -> {
            String className = classDecl.getNameAsString();
            String packageName = cu.getPackageDeclaration()
                .map(pd -> pd.getNameAsString())
                .orElse("");

            String fullyQualifiedName = packageName.isEmpty() ? className : packageName + "." + className;

            classDecl.getMethods().forEach(method -> {
                extractKafkaListenerFlows(method, fullyQualifiedName, messageFlows);
                extractSendToFlows(method, fullyQualifiedName, messageFlows);
                extractKafkaTemplateFlows(method, fullyQualifiedName, messageFlows);
            });
        });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



doc-architect/doc-architect-core/src/main/java/com/docarchitect/core/scanner/impl/java/KafkaScanner.java [336:349]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        cu.findAll(ClassOrInterfaceDeclaration.class).forEach(classDecl -> {
            String className = classDecl.getNameAsString();
            String packageName = cu.getPackageDeclaration()
                .map(pd -> pd.getNameAsString())
                .orElse("");

            String fullyQualifiedName = packageName.isEmpty() ? className : packageName + "." + className;

            classDecl.getMethods().forEach(method -> {
                extractKafkaListenerFlows(method, fullyQualifiedName, messageFlows);
                extractSendToFlows(method, fullyQualifiedName, messageFlows);
                extractKafkaTemplateFlows(method, fullyQualifiedName, messageFlows);
            });
        });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -