Update interface to ensure it remains consistent with message passing taxonomy

Author: daniyaltalatteo

README.md

@@ -70,7 +70,7 @@ const client = new KafkaClient({
 To send a message a topic, provide the topic name and the message. 
 
 ```js
-client.sendMessage(topic, message);
+client.publishToTopic(topic, message);
 ```
 
 ## Consuming Messages
@@ -82,7 +82,7 @@ The messages are consumed at an interval of 1 second with 10 messages consumed a
 To consume a message from a topic, provide the topic name and a callback function that would return the message.
 
 ```js
-client.consumeMessage(topic, onMessage);
+client.subscribeToTopic(topic, onMessage);
 ```
 
 ## Disconnection

__test__/index.test.js

@@ -22,21 +22,21 @@ describe('Kafka client integration tests', () => {
   });
 
   test('should log message when producer is connected', async () => {
-    await kafkaClient.sendMessage(topic, { message: 'Hello Cinemataztic' });
+    await kafkaClient.publishToTopic(topic, { message: 'Hello Cinemataztic' });
     expect(logSpy).toHaveBeenCalledWith(
       'Kafka producer successfully connected',
     );
   });
 
   test('should log message when consumer is connected', async () => {
-    await kafkaClient.consumeMessage(topic, () => {});
+    await kafkaClient.subscribeToTopic(topic, () => {});
     expect(logSpy).toHaveBeenCalledWith(
       'Kafka consumer successfully connected',
     );
   });
 
   test('should log message when consumer receives a message', async () => {
-    await kafkaClient.consumeMessage(topic, (data) => {
+    await kafkaClient.subscribeToTopic(topic, (data) => {
       expect(data).toHaveProperty('value');
       expect(data.value).toHaveProperty('message', 'Hello Cinemataztic');
     });
@@ -45,7 +45,7 @@ describe('Kafka client integration tests', () => {
     await new Promise((resolve) => setTimeout(resolve, 2000));
 
     // Send a message after consumer is ready.
-    await kafkaClient.sendMessage(topic, { message: 'Hello Cinemataztic' });
+    await kafkaClient.publishToTopic(topic, { message: 'Hello Cinemataztic' });
 
     // Wait for the polling (via setInterval) to pick up the message.
     await new Promise((resolve) => setTimeout(resolve, 5000));

src/index.js

@@ -243,7 +243,7 @@ class KafkaClient {
    * @param {Object} message The message to send to a topic
    * @public
    */
-  async sendMessage(topic, message) {
+  async publishToTopic(topic, message) {
     try {
       await this.#initProducer();
 
@@ -277,7 +277,7 @@ class KafkaClient {
    * @param {onMessage} onMessage A function that processes the decoded message data received by consumer
    * @public
    */
-  async consumeMessage(topic, onMessage) {
+  async subscribeToTopic(topic, onMessage) {
     try {
       await this.#initConsumer();