kafka_fdw

kafka Foreign Data Wrapper for CSV formatted messages

Overview

ID	Extension	Package	Version	Category	License	Language
8730	kafka_fdw	kafka_fdw	`0.0.3`	FDW	PostgreSQL	C

Attribute	Has Binary	Has Library	Need Load	Has DDL	Relocatable	Trusted
--s-d-r	No	Yes	No	Yes	yes	no

Relationships
See Also	pgmq mongo_fdw redis_fdw wrappers multicorn redis hdfs_fdw wal2json

Packages

Type	Repo	Version	PG Major Availability	Package Pattern	Dependencies
EL	PIGSTY	`0.0.3`	18 17 16 15 14 13	`kafka_fdw_$v`	-
Debian	PIGSTY	`0.0.3`	18 17 16 15 14 13	`postgresql-$v-kafka-fdw`	-

Linux / PG	PG18	PG17	PG16	PG15	PG14	PG13
el8.x86_64	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
el8.aarch64	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
el9.x86_64	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
el9.aarch64	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
el10.x86_64	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
el10.aarch64	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
d12.x86_64	MISS	MISS	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
d12.aarch64	MISS	MISS	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
d13.x86_64	MISS	MISS	MISS	MISS	MISS	MISS
d13.aarch64	MISS	MISS	MISS	MISS	MISS	MISS
u22.x86_64	MISS	MISS	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
u22.aarch64	MISS	MISS	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
u24.x86_64	MISS	MISS	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3
u24.aarch64	MISS	MISS	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3	PIGSTY 0.0.3

Package	Version	OS	ORG	SIZE	File URL
`kafka_fdw_18`	0.0.3	`el8.x86_64`	pigsty	34.6 KiB	kafka_fdw_18-0.0.3-2PIGSTY.el8.x86_64.rpm
`kafka_fdw_18`	0.0.3	`el8.aarch64`	pigsty	33.5 KiB	kafka_fdw_18-0.0.3-2PIGSTY.el8.aarch64.rpm
`kafka_fdw_18`	0.0.3	`el9.x86_64`	pigsty	33.5 KiB	kafka_fdw_18-0.0.3-2PIGSTY.el9.x86_64.rpm
`kafka_fdw_18`	0.0.3	`el9.aarch64`	pigsty	33.0 KiB	kafka_fdw_18-0.0.3-2PIGSTY.el9.aarch64.rpm
`kafka_fdw_18`	0.0.3	`el10.x86_64`	pigsty	34.6 KiB	kafka_fdw_18-0.0.3-2PIGSTY.el10.x86_64.rpm
`kafka_fdw_18`	0.0.3	`el10.aarch64`	pigsty	33.8 KiB	kafka_fdw_18-0.0.3-2PIGSTY.el10.aarch64.rpm

Package	Version	OS	ORG	SIZE	File URL
`kafka_fdw_17`	0.0.3	`el8.x86_64`	pigsty	34.6 KiB	kafka_fdw_17-0.0.3-2PIGSTY.el8.x86_64.rpm
`kafka_fdw_17`	0.0.3	`el8.aarch64`	pigsty	33.4 KiB	kafka_fdw_17-0.0.3-2PIGSTY.el8.aarch64.rpm
`kafka_fdw_17`	0.0.3	`el9.x86_64`	pigsty	33.5 KiB	kafka_fdw_17-0.0.3-2PIGSTY.el9.x86_64.rpm
`kafka_fdw_17`	0.0.3	`el9.aarch64`	pigsty	33.0 KiB	kafka_fdw_17-0.0.3-2PIGSTY.el9.aarch64.rpm
`kafka_fdw_17`	0.0.3	`el10.x86_64`	pigsty	34.5 KiB	kafka_fdw_17-0.0.3-2PIGSTY.el10.x86_64.rpm
`kafka_fdw_17`	0.0.3	`el10.aarch64`	pigsty	33.9 KiB	kafka_fdw_17-0.0.3-2PIGSTY.el10.aarch64.rpm

Package	Version	OS	ORG	SIZE	File URL
`kafka_fdw_16`	0.0.3	`el8.x86_64`	pigsty	37.0 KiB	kafka_fdw_16-0.0.3-2PIGSTY.el8.x86_64.rpm
`kafka_fdw_16`	0.0.3	`el8.x86_64`	pigsty	35.1 KiB	kafka_fdw_16-0.0.3-1PIGSTY.el8.x86_64.rpm
`kafka_fdw_16`	0.0.3	`el8.aarch64`	pigsty	35.4 KiB	kafka_fdw_16-0.0.3-2PIGSTY.el8.aarch64.rpm
`kafka_fdw_16`	0.0.3	`el8.aarch64`	pigsty	33.2 KiB	kafka_fdw_16-0.0.3-1PIGSTY.el8.aarch64.rpm
`kafka_fdw_16`	0.0.3	`el9.x86_64`	pigsty	35.3 KiB	kafka_fdw_16-0.0.3-1PIGSTY.el9.x86_64.rpm
`kafka_fdw_16`	0.0.3	`el9.x86_64`	pigsty	36.0 KiB	kafka_fdw_16-0.0.3-2PIGSTY.el9.x86_64.rpm
`kafka_fdw_16`	0.0.3	`el9.aarch64`	pigsty	34.4 KiB	kafka_fdw_16-0.0.3-1PIGSTY.el9.aarch64.rpm
`kafka_fdw_16`	0.0.3	`el9.aarch64`	pigsty	35.2 KiB	kafka_fdw_16-0.0.3-2PIGSTY.el9.aarch64.rpm
`kafka_fdw_16`	0.0.3	`el10.x86_64`	pigsty	36.8 KiB	kafka_fdw_16-0.0.3-2PIGSTY.el10.x86_64.rpm
`kafka_fdw_16`	0.0.3	`el10.aarch64`	pigsty	36.1 KiB	kafka_fdw_16-0.0.3-2PIGSTY.el10.aarch64.rpm
`postgresql-16-kafka-fdw`	0.0.3	`d12.x86_64`	pigsty	107.8 KiB	postgresql-16-kafka-fdw_0.0.3-1PIGSTY~bookworm_amd64.deb
`postgresql-16-kafka-fdw`	0.0.3	`d12.aarch64`	pigsty	105.4 KiB	postgresql-16-kafka-fdw_0.0.3-1PIGSTY~bookworm_arm64.deb
`postgresql-16-kafka-fdw`	0.0.3	`u22.x86_64`	pigsty	112.0 KiB	postgresql-16-kafka-fdw_0.0.3-1PIGSTY~jammy_amd64.deb
`postgresql-16-kafka-fdw`	0.0.3	`u22.aarch64`	pigsty	110.1 KiB	postgresql-16-kafka-fdw_0.0.3-1PIGSTY~jammy_arm64.deb
`postgresql-16-kafka-fdw`	0.0.3	`u24.x86_64`	pigsty	91.1 KiB	postgresql-16-kafka-fdw_0.0.3-1PIGSTY~noble_amd64.deb
`postgresql-16-kafka-fdw`	0.0.3	`u24.aarch64`	pigsty	89.9 KiB	postgresql-16-kafka-fdw_0.0.3-1PIGSTY~noble_arm64.deb

Package	Version	OS	ORG	SIZE	File URL
`kafka_fdw_15`	0.0.3	`el8.x86_64`	pigsty	35.4 KiB	kafka_fdw_15-0.0.3-1PIGSTY.el8.x86_64.rpm
`kafka_fdw_15`	0.0.3	`el8.x86_64`	pigsty	37.3 KiB	kafka_fdw_15-0.0.3-2PIGSTY.el8.x86_64.rpm
`kafka_fdw_15`	0.0.3	`el8.aarch64`	pigsty	35.6 KiB	kafka_fdw_15-0.0.3-2PIGSTY.el8.aarch64.rpm
`kafka_fdw_15`	0.0.3	`el8.aarch64`	pigsty	33.4 KiB	kafka_fdw_15-0.0.3-1PIGSTY.el8.aarch64.rpm
`kafka_fdw_15`	0.0.3	`el9.x86_64`	pigsty	36.1 KiB	kafka_fdw_15-0.0.3-1PIGSTY.el9.x86_64.rpm
`kafka_fdw_15`	0.0.3	`el9.x86_64`	pigsty	36.6 KiB	kafka_fdw_15-0.0.3-2PIGSTY.el9.x86_64.rpm
`kafka_fdw_15`	0.0.3	`el9.aarch64`	pigsty	35.1 KiB	kafka_fdw_15-0.0.3-1PIGSTY.el9.aarch64.rpm
`kafka_fdw_15`	0.0.3	`el9.aarch64`	pigsty	35.9 KiB	kafka_fdw_15-0.0.3-2PIGSTY.el9.aarch64.rpm
`kafka_fdw_15`	0.0.3	`el10.x86_64`	pigsty	37.4 KiB	kafka_fdw_15-0.0.3-2PIGSTY.el10.x86_64.rpm
`kafka_fdw_15`	0.0.3	`el10.aarch64`	pigsty	36.8 KiB	kafka_fdw_15-0.0.3-2PIGSTY.el10.aarch64.rpm
`postgresql-15-kafka-fdw`	0.0.3	`d12.x86_64`	pigsty	107.0 KiB	postgresql-15-kafka-fdw_0.0.3-1PIGSTY~bookworm_amd64.deb
`postgresql-15-kafka-fdw`	0.0.3	`d12.aarch64`	pigsty	104.7 KiB	postgresql-15-kafka-fdw_0.0.3-1PIGSTY~bookworm_arm64.deb
`postgresql-15-kafka-fdw`	0.0.3	`u22.x86_64`	pigsty	111.6 KiB	postgresql-15-kafka-fdw_0.0.3-1PIGSTY~jammy_amd64.deb
`postgresql-15-kafka-fdw`	0.0.3	`u22.aarch64`	pigsty	109.7 KiB	postgresql-15-kafka-fdw_0.0.3-1PIGSTY~jammy_arm64.deb
`postgresql-15-kafka-fdw`	0.0.3	`u24.x86_64`	pigsty	91.0 KiB	postgresql-15-kafka-fdw_0.0.3-1PIGSTY~noble_amd64.deb
`postgresql-15-kafka-fdw`	0.0.3	`u24.aarch64`	pigsty	89.9 KiB	postgresql-15-kafka-fdw_0.0.3-1PIGSTY~noble_arm64.deb

Package	Version	OS	ORG	SIZE	File URL
`kafka_fdw_14`	0.0.3	`el8.x86_64`	pigsty	35.4 KiB	kafka_fdw_14-0.0.3-1PIGSTY.el8.x86_64.rpm
`kafka_fdw_14`	0.0.3	`el8.x86_64`	pigsty	37.3 KiB	kafka_fdw_14-0.0.3-2PIGSTY.el8.x86_64.rpm
`kafka_fdw_14`	0.0.3	`el8.aarch64`	pigsty	33.4 KiB	kafka_fdw_14-0.0.3-1PIGSTY.el8.aarch64.rpm
`kafka_fdw_14`	0.0.3	`el8.aarch64`	pigsty	35.6 KiB	kafka_fdw_14-0.0.3-2PIGSTY.el8.aarch64.rpm
`kafka_fdw_14`	0.0.3	`el9.x86_64`	pigsty	36.1 KiB	kafka_fdw_14-0.0.3-1PIGSTY.el9.x86_64.rpm
`kafka_fdw_14`	0.0.3	`el9.x86_64`	pigsty	36.6 KiB	kafka_fdw_14-0.0.3-2PIGSTY.el9.x86_64.rpm
`kafka_fdw_14`	0.0.3	`el9.aarch64`	pigsty	35.9 KiB	kafka_fdw_14-0.0.3-2PIGSTY.el9.aarch64.rpm
`kafka_fdw_14`	0.0.3	`el9.aarch64`	pigsty	35.0 KiB	kafka_fdw_14-0.0.3-1PIGSTY.el9.aarch64.rpm
`kafka_fdw_14`	0.0.3	`el10.x86_64`	pigsty	37.4 KiB	kafka_fdw_14-0.0.3-2PIGSTY.el10.x86_64.rpm
`kafka_fdw_14`	0.0.3	`el10.aarch64`	pigsty	36.9 KiB	kafka_fdw_14-0.0.3-2PIGSTY.el10.aarch64.rpm
`postgresql-14-kafka-fdw`	0.0.3	`d12.x86_64`	pigsty	107.0 KiB	postgresql-14-kafka-fdw_0.0.3-1PIGSTY~bookworm_amd64.deb
`postgresql-14-kafka-fdw`	0.0.3	`d12.aarch64`	pigsty	104.8 KiB	postgresql-14-kafka-fdw_0.0.3-1PIGSTY~bookworm_arm64.deb
`postgresql-14-kafka-fdw`	0.0.3	`u22.x86_64`	pigsty	111.7 KiB	postgresql-14-kafka-fdw_0.0.3-1PIGSTY~jammy_amd64.deb
`postgresql-14-kafka-fdw`	0.0.3	`u22.aarch64`	pigsty	109.8 KiB	postgresql-14-kafka-fdw_0.0.3-1PIGSTY~jammy_arm64.deb
`postgresql-14-kafka-fdw`	0.0.3	`u24.x86_64`	pigsty	91.1 KiB	postgresql-14-kafka-fdw_0.0.3-1PIGSTY~noble_amd64.deb
`postgresql-14-kafka-fdw`	0.0.3	`u24.aarch64`	pigsty	90.0 KiB	postgresql-14-kafka-fdw_0.0.3-1PIGSTY~noble_arm64.deb

Package	Version	OS	ORG	SIZE	File URL
`kafka_fdw_13`	0.0.3	`el8.x86_64`	pigsty	35.0 KiB	kafka_fdw_13-0.0.3-1PIGSTY.el8.x86_64.rpm
`kafka_fdw_13`	0.0.3	`el8.x86_64`	pigsty	36.8 KiB	kafka_fdw_13-0.0.3-2PIGSTY.el8.x86_64.rpm
`kafka_fdw_13`	0.0.3	`el8.aarch64`	pigsty	33.3 KiB	kafka_fdw_13-0.0.3-1PIGSTY.el8.aarch64.rpm
`kafka_fdw_13`	0.0.3	`el8.aarch64`	pigsty	35.6 KiB	kafka_fdw_13-0.0.3-2PIGSTY.el8.aarch64.rpm
`kafka_fdw_13`	0.0.3	`el9.x86_64`	pigsty	36.6 KiB	kafka_fdw_13-0.0.3-2PIGSTY.el9.x86_64.rpm
`kafka_fdw_13`	0.0.3	`el9.x86_64`	pigsty	36.0 KiB	kafka_fdw_13-0.0.3-1PIGSTY.el9.x86_64.rpm
`kafka_fdw_13`	0.0.3	`el9.aarch64`	pigsty	35.0 KiB	kafka_fdw_13-0.0.3-1PIGSTY.el9.aarch64.rpm
`kafka_fdw_13`	0.0.3	`el9.aarch64`	pigsty	35.8 KiB	kafka_fdw_13-0.0.3-2PIGSTY.el9.aarch64.rpm
`kafka_fdw_13`	0.0.3	`el10.x86_64`	pigsty	37.2 KiB	kafka_fdw_13-0.0.3-2PIGSTY.el10.x86_64.rpm
`kafka_fdw_13`	0.0.3	`el10.aarch64`	pigsty	36.7 KiB	kafka_fdw_13-0.0.3-2PIGSTY.el10.aarch64.rpm
`postgresql-13-kafka-fdw`	0.0.3	`d12.x86_64`	pigsty	106.0 KiB	postgresql-13-kafka-fdw_0.0.3-1PIGSTY~bookworm_amd64.deb
`postgresql-13-kafka-fdw`	0.0.3	`d12.aarch64`	pigsty	104.0 KiB	postgresql-13-kafka-fdw_0.0.3-1PIGSTY~bookworm_arm64.deb
`postgresql-13-kafka-fdw`	0.0.3	`u22.x86_64`	pigsty	110.4 KiB	postgresql-13-kafka-fdw_0.0.3-1PIGSTY~jammy_amd64.deb
`postgresql-13-kafka-fdw`	0.0.3	`u22.aarch64`	pigsty	108.9 KiB	postgresql-13-kafka-fdw_0.0.3-1PIGSTY~jammy_arm64.deb
`postgresql-13-kafka-fdw`	0.0.3	`u24.x86_64`	pigsty	90.7 KiB	postgresql-13-kafka-fdw_0.0.3-1PIGSTY~noble_amd64.deb
`postgresql-13-kafka-fdw`	0.0.3	`u24.aarch64`	pigsty	89.8 KiB	postgresql-13-kafka-fdw_0.0.3-1PIGSTY~noble_arm64.deb

Source

Repository

github.com/adjust/kafka_fdw

Source Tarball

kafka_fdw-0.0.3.tar.gz

pig build get kafka_fdw; # get kafka_fdw source code
pig build dep kafka_fdw; # install build dependencies
pig build pkg kafka_fdw; # build extension rpm or deb
pig build ext kafka_fdw; # build extension rpms

Install

To add the required PGDG / PIGSTY upstream repository, use:

pig repo add pgsql -u   # add PGDG + Pigsty repo and update cache (leave existing repos)

Install this extension with:

pig ext install kafka_fdw; # install by extension name, for the current active PG version
pig ext install kafka_fdw; # install via package alias, for the active PG version
pig ext install kafka_fdw -v 18;   # install for PG 18
pig ext install kafka_fdw -v 17;   # install for PG 17
pig ext install kafka_fdw -v 16;   # install for PG 16
pig ext install kafka_fdw -v 15;   # install for PG 15
pig ext install kafka_fdw -v 14;   # install for PG 14
pig ext install kafka_fdw -v 13;   # install for PG 13

Create this extension with:

CREATE EXTENSION kafka_fdw;

Last updated on 2025-11-02

redis hdfs_fdw