public class SampleClass {
private Dependency dependency;
public SampleClass(Dependency dependency) {
this.dependency = dependency;
}
// ...
}
@Entity
@Table(name = "employees")
public class Employee {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
@Column(name = "name")
private String name;
// ...
}
public class UserController extends ActionSupport {
private String username;
private String password;
public String execute() {
// ...
return SUCCESS;
}
// ...
}
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<>("my-topic", "key", "value"));
producer.close();
