SpringBoot StringKafkaTemplate Conductor Kafka Topic Producer Consumer

Wanna produce and consume from Kafka topics with SpringBoot ?

Wanna watch your Kafka Topics via Conductor ?

Wanna send some rest request to produce data to send your Kafka topic ?

Don't wanna write code ?

Get The Code

Just checkout and sit back :) 

Your custom java annotation and check for it on the classes with reflection

Just another copy paste run bye article !

	package com.example.customannotation;
	import java.lang.annotation.*;
	import java.lang.reflect.Method;
	import java.util.ArrayList;
	import java.util.List;
	@Retention(RetentionPolicy.RUNTIME)
	@Target(ElementType.METHOD)
	public @interface MyCustomAnnotation {
	String name();
	String surname();
	}
	class SomeClass {
	@MyCustomAnnotation(name = "serkan", surname = "sunel")
	public void someMethod(String someParameter) {
	System.out.println("Hello annotation world !!" + someParameter);
	}
	}
	class AnnotationProcessorWithReflection {
	public static void main(String[] args) {
	SomeClass someClass = new SomeClass();
	List<Method> methodsAnnotatedWith = getMethodsAnnotatedWith(someClass.getClass(), MyCustomAnnotation.class);
	methodsAnnotatedWith.stream().forEach(m -> System.out.println(" Method name " + m.getName()));
	}
	private static List<Method> getMethodsAnnotatedWith(final Class<?> type, final Class<? extends Annotation> annotation) {
	final List<Method> methods = new ArrayList<>();
	Class<?> klass = type;
	while (klass != Object.class) {
	for (final Method method : klass.getDeclaredMethods()) {
	if (method.isAnnotationPresent(annotation)) {
	Annotation annotInstance = method.getAnnotation(annotation);
	System.out.println("annotInstance = " + annotInstance + " found on the class: " + type);
	methods.add(method);
	}
	}
	klass = klass.getSuperclass();
	}
	return methods;
	}
	}

view raw MyCustomAnnotation.java hosted with ❤ by GitHub