open-index/open-npm huggingface dataset:
npm package: @kafkats/client
Description: Pure-protocol Kafka client, consumer/producer, and EOS patterns in TypeScript.
Latest version: 0.7.0

# @kafkats/client

A pure-protocol TypeScript Kafka client with producer, consumer, and admin APIs.

## Features

- **Pure TypeScript** — Direct protocol implementation, not a wrapper
- **Producer** — Batching, compression (gzip, snappy, lz4, zstd), custom partitioners
- **Consumer** — Consumer groups, partition assignment, offset management
- **ShareConsumer (experimental)** — Share Groups (KIP-932) with per-record acknowledgements
- **Admin** — Topic management, consumer groups, cluster metadata
- **SASL Auth** — PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER
- **Typed Codecs** — Built-in string, JSON, and buffer codecs

## Installation

```bash
npm install @kafkats/client
```

## Usage

```typescript
import { KafkaClient } from '@kafkats/client'

const client = new KafkaClient({ brokers: ['localhost:9092'] })

// Producer
const producer = client.producer()
await producer.connect()
await producer.send('events', [{ key: 'user-1', value: 'hello' }])

// SASL OAUTHBEARER (e.g. AWS MSK IAM)
const clientWithSasl = new KafkaClient({
	brokers: ['b-1.example:9098'],
	clientId: 'my-app',
	tls: { enabled: true },
	sasl: {
		mechanism: 'OAUTHBEARER',
		oauthBearerProvider: async ({ host, port }) => ({
			value: await getTokenForBroker(`${host}:${port}`),
		}),
	},
})

// Consumer
const consumer = client.consumer({ groupId: 'my-group' })
await consumer.runEach('events', async (message, ctx) => {
	console.log(message.value?.toString())
})

// ShareConsumer (experimental)
const shareConsumer = client.shareConsumer({ groupId: 'my-share-group' })
await shareConsumer.runEach('events', async message => {
	console.log(message.value?.toString())
	// If you don't call ack/release/reject, the message is implicitly ack'd (ACCEPT) on success.
})

// Admin
const admin = client.admin()
await admin.connect()
await admin.createTopics([{ name: 'events', partitions: 3 }])
```

## Documentation

Full documentation at [chrisrecalis.github.io/kafkats](https://chrisrecalis.github.io/kafkats)

## License

MIT
npm package: @kafkats/codec-zod
Description: Zod codec helpers for @kafkats/client.
Latest version: 0.7.0

# @kafkats/codec-zod

Zod schema validation codecs for `@kafkats/client`.

## Installation

```bash
npm install @kafkats/client @kafkats/codec-zod zod
```

## Usage

```typescript
import { KafkaClient } from '@kafkats/client'
import { zodCodec } from '@kafkats/codec-zod'
import { z } from 'zod'

const UserEvent = z.object({
	userId: z.string(),
	action: z.enum(['login', 'logout', 'purchase']),
	timestamp: z.number(),
})

const client = new KafkaClient({ brokers: ['localhost:9092'] })
const producer = client.producer()

await producer.send(
	'user-events',
	[
		{
			key: 'user-1',
			value: { userId: 'user-1', action: 'login', timestamp: Date.now() },
		},
	],
	{ valueCodec: zodCodec(UserEvent) }
)
```

## Documentation

Full documentation at [chrisrecalis.github.io/kafkats](https://chrisrecalis.github.io/kafkats)

## License

MIT
npm package: @kafkats/flow
Description: Flow-level APIs built on top of @kafkats/client.
Latest version: 0.7.0

# @kafkats/flow

Kafka Streams-like DSL for stream processing in TypeScript.

## Features

- **Stream DSL** — map, filter, branch, flatMap, and more
- **Tables** — KTable with changelog-backed state
- **Aggregations** — groupByKey, count, aggregate, reduce
- **Windowing** — Tumbling, hopping, sliding, and session windows
- **Joins** — Stream-stream and stream-table joins
- **State Stores** — Pluggable state with in-memory default
- **Testing** — Built-in TestDriver for unit testing topologies

## Installation

```bash
npm install @kafkats/client @kafkats/flow
```

## Usage

```typescript
import { KafkaClient } from '@kafkats/client'
import { flow } from '@kafkats/flow'

const client = new KafkaClient({ brokers: ['localhost:9092'] })

const app = flow(client, { applicationId: 'my-app' })

app.stream('input-topic')
	.filter((key, value) => value.includes('important'))
	.mapValues(value => value.toUpperCase())
	.to('output-topic')

await app.start()
```

### Testing

```typescript
import { TestDriver, testRecord } from '@kafkats/flow/testing'

const driver = new TestDriver(app)
await driver.send('input-topic', testRecord('key', 'important message'))
const output = await driver.collect('output-topic')
```

## Documentation

Full documentation at [chrisrecalis.github.io/kafkats](https://chrisrecalis.github.io/kafkats)

## License

MIT
npm package: @kafkats/flow-state-lmdb
Description: LMDB state store provider for @kafkats/flow
Latest version: 0.7.0

# @kafkats/flow-state-lmdb

Persistent LMDB state stores for `@kafkats/flow`.

## Features

- **Persistent State** — Survives application restarts
- **Memory-Mapped** — Fast reads via LMDB
- **All Store Types** — KeyValue, Window, and Session stores

## Installation

```bash
npm install @kafkats/flow @kafkats/flow-state-lmdb
```

## Usage

```typescript
import { KafkaClient } from '@kafkats/client'
import { flow } from '@kafkats/flow'
import { lmdb } from '@kafkats/flow-state-lmdb'

const client = new KafkaClient({ brokers: ['localhost:9092'] })

const app = flow(client, {
	applicationId: 'my-app',
	stateStoreProvider: lmdb({ stateDir: './state' }),
})

app.stream('events').groupByKey().count().toStream().to('counts')

await app.start()
```

## Options

```typescript
lmdb({
	stateDir: './state', // Directory for state files
	mapSize: 1024 ** 3, // Max database size (default: 1GB)
	maxDbs: 100, // Max number of stores (default: 100)
})
```

## Documentation

Full documentation at [chrisrecalis.github.io/kafkats](https://chrisrecalis.github.io/kafkats)

## License

MIT
npm package: @kafudev/react-native-alibc
Description: 阿里百川sdk
Author: kafudev
Latest version: 0.1.19

# react-native-alibc

阿里百川sdk

## Installation

```sh
npm install @kafudev/react-native-alibc
```

## Usage

```js
import Alibc from "@kafudev/react-native-alibc";

// ...

const result = await Alibc.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-alipay
Description: 支付宝SDK
Author: kafudev
Latest version: 0.1.11

# react-native-alipay

支付宝SDK

## Installation

```sh
npm install react-native-alipay
```

## Usage

```js
import Alipay from "@kafudev/react-native-alipay";

// ...

const result = await Alipay.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-ble
Description: react-native低功耗蓝牙通信
Author: kafudev
Latest version: 0.1.1

# react-native-ble

react-native低功耗蓝牙通信

## Installation

```sh
npm install react-native-ble
```

## Usage

```js
import Ble from "react-native-ble";

// ...

const result = await Ble.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-bugly
Description: react-native bugly 异常上报和运营统计
Author: kafudev
Latest version: 0.1.13

# react-native-bugly

react-native bugly 异常上报和运营统计

## Installation

```sh
npm install @kafudev/react-native-bugly
```

## Usage

```js
import Bugly from "@kafudev/react-native-bugly";

// ...

const result = await Bugly.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-echarts
Description: Echarts图表，react-native-echarts
Author: kafudev
Latest version: 0.1.5

# react-native-echarts

Echarts图表，react-native-echarts

## Installation

```sh
npm install react-native-echarts
```

## Usage

```js
import Echarts from "react-native-echarts";

// ...

const result = await Echarts.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-esp-idf
Description: ReactNative Provisioning application for ESP-IDF Unified provisioning
Author: kafudev
Latest version: 0.4.0

# react-native-esp-idf

ReactNative Provisioning application for ESP-IDF Unified provisioning

## Installation

```sh
npm install @kafudev/react-native-esp-idf
```

## Note
This package is based on [react-native-esp32-idf](https://www.npmjs.com/package/react-native-esp32-idf)
This package is based on [react-native-esp-idf](https://www.npmjs.com/package/react-native-esp-idf)

with the above package without connecting to bluetooth one cannot connect to wifi of esp device, to slove that issue made neccessary changes to the code .
Now one can connect to esp device wifi without connecting to bluetooth.

Supports Both Android and IOS


## Usage

```js
import RNEspIdf, {useProvisioning} from "@kafudev/react-native-esp-idf";

// ...

// connect to esp device through wifi
// first connect to the hotspot of the device and later
const devicePrefix = 'PROV_'
	const message: MessageInfo = {
		scanBle: 'Searching device...',
		scanWifi: 'Searching available Wi-Fi...',
		connectDevice: 'Connecting your device...',
		sendingWifiCredential: 'Sending Wi-Fi credentials',
		confirmWifiConnection: 'Confirming Wi-Fi connection',
		enableBluetooth: 'Please enable the Bluetooth to start scan device.',
		enableLocation:
			'Please grant location permission to start scan device.',
		scanBleFailed: 'Scan device failed, please try again.',
		connectFailed: 'Connect to device failed, please try again.',
		disconnected: 'device disconnected, please try again.',
		initSessionError: 'Reboot your device and retry.',
		applyError: 'Reset your device and retry.',
		completed: 'Device has been successfully provisioned!',
	}
	const {
		bleDevices,
		wifiAPs,
		loading,
		status,
		currentStep,
		currentWifi,
		currentDevice,
		results,
		setCurrentStep,
		configWifi,
		connectDevice,
		connectWifiDevice, //newly added
		doProvisioning,
	} = useProvisioning({ devicePrefix, message, pop: 'abcd1234' })



// android example
const connectToEspDevice = async()=>{
    try{
        const result = await RNEspIdf.connectWifiDevice("pop"); //proof of possession

    }
    catch(err){
        console.log(err)

    }
}


// ios example
const connectToEspDevice = async()=>{
	try{
		let pop = ""
		let SSID =""
		let Password=""
		const result = await RNEspIdf.connectWifiDevice(SSID,POP,Password)

	}
	catch(err){
		console.log(err)
	}
}



```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT

---

Made with [create-react-native-library](https://github.com/callstack/react-native-builder-bob)
npm package: @kafudev/react-native-orientation
Description: react-native orientation
Author: kafudev
Latest version: 0.1.9

# react-native-orientation

react-native orientation

## Installation

```sh
npm install @kafudev/react-native-orientation
```

## Usage

```js
import Orientation from "@kafudev/react-native-orientation";

// ...

const result = await Orientation.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-qiyu
Description: react-native netease qiyu sdk
Author: kafudev
Latest version: 0.1.48

# react-native-qiyu

react-native netease qiyu sdk

## Installation

```sh
npm install @kafudev/react-native-qiyu
```

## Usage

```js
import Qiyu from "@kafudev/react-native-qiyu";

// ...

const result = await Qiyu.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-txlive
Description: react-native-txlive 腾讯移动直播SDK
Author: kafudev
Latest version: 0.1.38

# react-native-txlive

react-native-txlive 腾讯移动直播SDK

## Installation

```sh
npm install react-native-txlive
```

## Usage

```js
import Txlive from "react-native-txlive";

// ...

const result = await Txlive.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-txplayer
Description: react-native-txplayer 腾讯播放器SDK
Author: kafudev
Latest version: 0.1.3

# react-native-txplayer

react-native-txplayer 腾讯播放器SDK

## Installation

```sh
npm install react-native-txplayer
```

## Usage

```js
import Txplayer from "react-native-txplayer";

// ...

const result = await Txplayer.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-txugsv
Description: react-native-txugsv 腾讯短视频UGSV
Author: kafudev
Latest version: 0.1.2

# react-native-txugsv

react-native-txugsv 腾讯短视频UGSV

## Installation

```sh
npm install react-native-txugsv
```

## Usage

```js
import Txugsv from "react-native-txugsv";

// ...

const result = await Txugsv.multiply(3, 7);
```

## Contributing

See the [contributing guide](CONTRIBUTING.md) to learn how to contribute to the repository and the development workflow.

## License

MIT
npm package: @kafudev/react-native-vconsole
Description: vConsole for react native
Author: kafudev
Latest version: 0.1.11

# react-native-vconsole

vConsole for react native

## Features

1. console[log, warn, error, info] in Log Panel.
2. Network request list & detail.
3. Customized Version Info you want to show.

## Installation

```sh
$ yarn add @kafudev/react-native-vconsole
// or
npm i @kafudev/react-native-vconsole
```

## Usage


可接受参数
```
interface PropsType {
  appInfo?: {}
  console?: boolean
  panels?: {
    title: string
    component: React.ReactNode
  }
}
```

```javascript
import VConsole from '@kafudev/react-native-vconsole'
/* INFO is optional */

// in render function
render() {
  return (
    <View>
        <VConsole
            // 使用 'react-native-config-reader' 库获获取额外信息
            appInfo={{
                原生构建类型: ConfigReader.BUILD_TYPE,
                原生版本号: ConfigReader.VERSION_NAME || ConfigReader.CFBundleShortVersionString,
                原生构建时间: ConfigReader.BUILD_TIME,
                热更新版本号: codePushStore.info.label,
                热更新详情: codePushStore.info.desc,
            }}
            // 另外的的面板
            panels={panels}
            // console.time 可辨别是否开启 debug 网页
            console={__DEV__ ? !console.time : true}
        />
    </View>
  )
}
```


# 鸣谢

vConsole for react native

本插件集合了多种vconsole的优点，感谢以下库:

https://github.com/itenl/react-native-vdebug
https://github.com/Grewer/react-native-vconsole
https://github.com/fwon/RNVConsole
https://github.com/sigmayun/react-native-vconsole


## License

MIT