const { Kafka } = require('kafkajs');

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['localhost:9092']
});

const admin = kafka.admin();

async function createTopic() {
  try {
    await admin.connect();
    await admin.createTopics({
      topics: [{
        topic: 'my-topic-1',
        numPartitions: 2,
        replicationFactor: 1
      }]
    });
    console.log('Topic created successfully!');
  } catch (error) {
    console.error('Error creating topic:', error);
  } finally {
    await admin.disconnect();
  }
}

createTopic();