vikrambiwal

		client := &kafkago.Client{
			Addr:    kafkago.TCP("127.0.0.1:9092"),
			Timeout: 10 * time.Second,
		}
		ctx := context.Background()
		descReq := &kafkago.DescribeGroupsRequest{
			GroupIDs: []string{"test-topic-group"},
		}

vikrambiwal

process.stdin.resume();
process.stdin.setEncoding('utf-8');

var input_ = "";

process.stdin.on('data', function (data) {
    input_ += data.toString().trim();
    input_ += '\n';
});

vikrambiwal

package main

import (
	"context"
	"fmt"
	"time"
)

func main() {
	

vikrambiwal

const fs = require('fs');
const path = require('path');

if (process.argv.length <= 2) {
	console.log('Usage: ' + __filename + ' path/to/directory');
	process.exit(-1);
}

var directoryPath = process.argv[2];
fs.readdir(directoryPath, (err, files) => {