import com.example.messagequeue.KafkaClient;
public class MessageQueueClient {
private KafkaClient client;
public MessageQueueClient(String url, String username, String password) {
this.client = new KafkaClient(url, username, password);
}
public void sendMessage(String topic, String message) {
this.client.sendMessage(topic, message);
}
public void consumeMessage(String topic, String consumerGroup) {
this.client.consumeMessage(topic, consumerGroup);
}
public static void main(String[] args) {
MessageQueueClient client = new MessageQueueClient("kafka://localhost:9092", "admin", "password");
client.sendMessage("test", "Hello World!");
client.consumeMessage("test", "consumer-group");
}
}
