connect
Fancy stream processing made operationally mundane
File Explorer
Download Latest Version (.zip)- godev.md
- tester.md
- SKILL.md
- SKILL.md
- review-policy.md
- settings.json
- bloblang-authoring-0.2.0.zip
- component-search-0.2.0.zip
- pipeline-assistant-0.2.0.zip
- plugin.json
- blobl.md
- pipeline.md
- search.md
- format-bloblang.py
- format-bloblang.sh
- rpk-version.sh
- test-blobl.sh
- SETUP.md
- SKILL.md
- format-component-fields.py
- format-component-fields.sh
- rpk-version.sh
- SETUP.md
- SKILL.md
- cdc-replication.md
- cdc-replication.yaml
- content-based-router.md
- content-based-router.yaml
- custom-metrics.md
- custom-metrics.yaml
- dlq-basic.md
- dlq-basic.yaml
- kafka-replication.md
- kafka-replication.yaml
- multicast.md
- multicast.yaml
- rate-limiting.md
- rate-limiting.yaml
- s3-polling.md
- s3-polling.yaml
- s3-sink-basic.md
- s3-sink-basic.yaml
- s3-sink-time-based.md
- s3-sink-time-based.yaml
- stateful-counter.md
- stateful-counter.yaml
- validate.sh
- window-aggregation.md
- window-aggregation.yaml
- SETUP.md
- SKILL.md
- blobl_transformations.json
- pipeline_descriptions.json
- search_queries.json
- marketplace.json
- README.md
- action.yml
- action.yml
- release-notes-classifier.json
- release-notes-classifier.txt
- auto-label-integration.yml
- claude-code-review.yml
- integration_test.yml
- release-auto-tag.yml
- release-notes.yml
- release.yml
- release_python_sdk.yaml
- tag-bundles.yml
- test.yml
- test_plugin_uploader.yml
- ai-opt-out
- dependabot.yaml
- rules.go
- connect-ai.yaml
- connect-cgo.yaml
- connect-cloud.yaml
- connect-fips.yaml
- connect-lambda.yaml
- connect.yaml
- settings.json
- main.go
- main.go
- sqlite.go
- main.go
- sqlite.go
- main.go
- main.go
- bloblang_about.adoc.tmpl
- bloblang_functions.adoc.tmpl
- bloblang_methods.adoc.tmpl
- http.adoc.tmpl
- logger.adoc.tmpl
- plugin.adoc.tmpl
- plugin_fields.adoc.tmpl
- redpanda.adoc.tmpl
- templates.adoc.tmpl
- tests.adoc.tmpl
- bloblang_test.go
- main.go
- schema_test.go
- appended.txt
- fail.txt
- incomplete.txt
- mixed.txt
- pass.txt
- skip.txt
- skip_tab_indent.txt
- cache.go
- cache_test.go
- docker.go
- events.go
- main.go
- output.go
- packages.go
- packages.json
- README.md
- run.go
- show.go
- show_test.go
- utils.go
- utils_test.go
- main.go
- main.go
- resources.yaml
- set_grab_cache.yaml
- aws_cloudwatch_logs.yaml
- cdc_replication.yaml
- discord_bot.yaml
- dynamodb_cdc_global_table.yaml
- jira_input.yaml
- joining_streams.yaml
- site_analytics.yaml
- stateful_polling.yaml
- string_split.yaml
- track_benthos_downloads.yaml
- cohere_pgvector.yaml
- ollama_pgvector.yaml
- openai_pgvector.yaml
- redpanda-docs.yaml
- cohere_pgvector.yaml
- ollama_pgvector.yaml
- openai_pgvector.yaml
- cohere_embeddings.yaml
- ollama_embeddings.yaml
- openai_embeddings.yaml
- pgvector_output.yaml
- pgvector_query.yaml
- redpanda.yaml
- .gitignore
- docker-compose.yml
- env.sample
- eval.yaml
- README.md
- rpk.profile.yaml
- input_sqs_example.yaml
- input_stdin_uppercase.yaml
- output_dead_letter.yaml
- processor_hydration.yaml
- processor_log_and_drop.yaml
- processor_log_message.yaml
- processor_plugin_alias.yaml
- also_tests_boolean_operands.yaml
- boolean_operands.yaml
- cities.blobl
- cities_test.yaml
- csv.yaml
- csv_formatter.blobl
- csv_formatter_test.yaml
- env.yaml
- fans.yaml
- github_releases.blobl
- github_releases_test.yaml
- literals.yaml
- message_expansion.yaml
- walk_json.yaml
- windowed.yaml
- filtering.yaml
- filtering_benthos_test.yaml
- input.txt
- output.txt
- .envelope_.proto
- .house_.proto
- .person_.proto
- envelope.proto
- house.proto
- person.proto
- serde_test.proto
- house.yaml
- people.yaml
- other_mappings.yaml
- other_mappings_benthos_test.yaml
- some_mappings.yaml
- awk.yaml
- awk_benthos_test.yaml
- deduplicate.yaml
- deduplicate_by_batch.yaml
- deduplicate_lru.yaml
- deduplicate_ttlru.yaml
- env_var_stuff.yaml
- files_for_content.yaml
- filters.yaml
- infile_resource_mock.yaml
- json_contains_predicate.yaml
- mock_http_proc.yaml
- mock_http_proc_path.yaml
- structured_metadata.yaml
- unit_test_example.yaml
- unit_test_example_benthos_test.yaml
- .gitignore
- docker.yaml
- README.md
- aws-s3.md
- dynamodb-cdc.md
- iceberg.md
- mssqlserver-cdc.md
- mysql-cdc.md
- oracledb-cdc.md
- postgres.md
- redpanda-migrator.md
- salesforce.md
- SUMMARY.md
- memory.adoc
- none.adoc
- sqlite.adoc
- system_window.adoc
- aws_dynamodb.adoc
- aws_s3.adoc
- couchbase.adoc
- file.adoc
- gcp_cloud_storage.adoc
- lru.adoc
- memcached.adoc
- memory.adoc
- mongodb.adoc
- multilevel.adoc
- nats_kv.adoc
- noop.adoc
- redis.adoc
- redpanda.adoc
- ristretto.adoc
- sql.adoc
- ttlru.adoc
- about.adoc
- amqp_0_9.adoc
- amqp_1.adoc
- aws_cloudwatch_logs.adoc
- aws_dynamodb_cdc.adoc
- aws_kinesis.adoc
- aws_s3.adoc
- aws_sqs.adoc
- azure_blob_storage.adoc
- azure_cosmosdb.adoc
- azure_queue_storage.adoc
- azure_table_storage.adoc
- batched.adoc
- beanstalkd.adoc
- broker.adoc
- cassandra.adoc
- cockroachdb_changefeed.adoc
- csv.adoc
- discord.adoc
- dynamic.adoc
- file.adoc
- gateway.adoc
- gcp_bigquery_select.adoc
- gcp_cloud_storage.adoc
- gcp_pubsub.adoc
- gcp_spanner_cdc.adoc
- generate.adoc
- git.adoc
- hdfs.adoc
- http_client.adoc
- http_server.adoc
- inproc.adoc
- jira.adoc
- kafka.adoc
- kafka_franz.adoc
- microsoft_sql_server_cdc.adoc
- mongodb.adoc
- mongodb_cdc.adoc
- mqtt.adoc
- mysql_cdc.adoc
- nanomsg.adoc
- nats.adoc
- nats_jetstream.adoc
- nats_kv.adoc
- nats_stream.adoc
- nsq.adoc
- ockam_kafka.adoc
- oracledb_cdc.adoc
- otlp_grpc.adoc
- otlp_http.adoc
- parquet.adoc
- pg_stream.adoc
- postgres_cdc.adoc
- pulsar.adoc
- read_until.adoc
- redis_list.adoc
- redis_pubsub.adoc
- redis_scan.adoc
- redis_streams.adoc
- redpanda.adoc
- redpanda_common.adoc
- redpanda_migrator.adoc
- resource.adoc
- salesforce.adoc
- salesforce_cdc.adoc
- salesforce_graphql.adoc
- schema_registry.adoc
- sequence.adoc
- sftp.adoc
- slack.adoc
- slack_users.adoc
- socket.adoc
- socket_server.adoc
- spicedb_watch.adoc
- splunk.adoc
- sql_raw.adoc
- sql_select.adoc
- stdin.adoc
- subprocess.adoc
- tigerbeetle_cdc.adoc
- timeplus.adoc
- twitter_search.adoc
- websocket.adoc
- zmq4.adoc
- about.adoc
- aws_cloudwatch.adoc
- influxdb.adoc
- json_api.adoc
- logger.adoc
- none.adoc
- open_telemetry_collector.adoc
- prometheus.adoc
- statsd.adoc
- amqp_0_9.adoc
- amqp_1.adoc
- arc.adoc
- aws_dynamodb.adoc
- aws_kinesis.adoc
- aws_kinesis_firehose.adoc
- aws_s3.adoc
- aws_sns.adoc
- aws_sqs.adoc
- azure_blob_storage.adoc
- azure_cosmosdb.adoc
- azure_data_lake_gen2.adoc
- azure_queue_storage.adoc
- azure_table_storage.adoc
- beanstalkd.adoc
- bigquery_cdc_migration.adoc
- broker.adoc
- cache.adoc
- cassandra.adoc
- couchbase.adoc
- cyborgdb.adoc
- cypher.adoc
- discord.adoc
- doris_stream_load.adoc
- drop.adoc
- drop_on.adoc
- dynamic.adoc
- elasticsearch_v8.adoc
- elasticsearch_v9.adoc
- fallback.adoc
- file.adoc
- gcp_bigquery.adoc
- gcp_bigquery_write_api.adoc
- gcp_cloud_storage.adoc
- gcp_pubsub.adoc
- hdfs.adoc
- http_client.adoc
- http_server.adoc
- iceberg.adoc
- inproc.adoc
- kafka.adoc
- kafka_franz.adoc
- mongodb.adoc
- mqtt.adoc
- nanomsg.adoc
- nats.adoc
- nats_jetstream.adoc
- nats_kv.adoc
- nats_stream.adoc
- nsq.adoc
- ockam_kafka.adoc
- opensearch.adoc
- otlp_grpc.adoc
- otlp_http.adoc
- pinecone.adoc
- pulsar.adoc
- pusher.adoc
- qdrant.adoc
- questdb.adoc
- redis_hash.adoc
- redis_list.adoc
- redis_pubsub.adoc
- redis_streams.adoc
- redpanda.adoc
- redpanda_common.adoc
- redpanda_migrator.adoc
- reject.adoc
- reject_errored.adoc
- resource.adoc
- retry.adoc
- salesforce_sink.adoc
- schema_registry.adoc
- sftp.adoc
- slack_post.adoc
- slack_reaction.adoc
- snowflake_put.adoc
- snowflake_streaming.adoc
- socket.adoc
- splunk_hec.adoc
- sql.adoc
- sql_insert.adoc
- sql_raw.adoc
- stdout.adoc
- subprocess.adoc
- switch.adoc
- sync_response.adoc
- timeplus.adoc
- websocket.adoc
- zmq4.adoc
- archive.adoc
- avro.adoc
- awk.adoc
- aws_bedrock_chat.adoc
- aws_bedrock_embeddings.adoc
- aws_dynamodb_partiql.adoc
- aws_lambda.adoc
- azure_cosmosdb.adoc
- benchmark.adoc
- bloblang.adoc
- bounds_check.adoc
- branch.adoc
- cache.adoc
- cached.adoc
- catch.adoc
- cohere_chat.adoc
- cohere_embeddings.adoc
- cohere_rerank.adoc
- command.adoc
- compress.adoc
- couchbase.adoc
- crash.adoc
- decompress.adoc
- dedupe.adoc
- ffi.adoc
- for_each.adoc
- gcp_bigquery_select.adoc
- gcp_vertex_ai_chat.adoc
- gcp_vertex_ai_embeddings.adoc
- google_drive_download.adoc
- google_drive_get_labels.adoc
- google_drive_list_labels.adoc
- google_drive_search.adoc
- grok.adoc
- group_by.adoc
- group_by_value.adoc
- http.adoc
- insert_part.adoc
- javascript.adoc
- jira.adoc
- jmespath.adoc
- jq.adoc
- json_schema.adoc
- log.adoc
- mapping.adoc
- metric.adoc
- mongodb.adoc
- msgpack.adoc
- mutation.adoc
- nats_kv.adoc
- nats_request_reply.adoc
- noop.adoc
- ollama_chat.adoc
- ollama_embeddings.adoc
- ollama_moderation.adoc
- openai_chat_completion.adoc
- openai_embeddings.adoc
- openai_image_generation.adoc
- openai_speech.adoc
- openai_transcription.adoc
- openai_translation.adoc
- parallel.adoc
- parquet.adoc
- parquet_decode.adoc
- parquet_encode.adoc
- parse_log.adoc
- processors.adoc
- protobuf.adoc
- qdrant.adoc
- rate_limit.adoc
- redis.adoc
- redis_script.adoc
- redpanda_data_transform.adoc
- resource.adoc
- retry.adoc
- salesforce.adoc
- schema_registry_decode.adoc
- schema_registry_encode.adoc
- select_parts.adoc
- sentry_capture.adoc
- slack_thread.adoc
- sleep.adoc
- split.adoc
- sql.adoc
- sql_insert.adoc
- sql_raw.adoc
- sql_select.adoc
- string_split.adoc
- subprocess.adoc
- switch.adoc
- sync_response.adoc
- text_chunker.adoc
- try.adoc
- try_catch.adoc
- unarchive.adoc
- wasm.adoc
- while.adoc
- workflow.adoc
- xml.adoc
- local.adoc
- redis.adoc
- about.adoc
- avro.adoc
- chunker.adoc
- csv.adoc
- decompress.adoc
- json_array.adoc
- json_documents.adoc
- lines.adoc
- re_match.adoc
- skip_bom.adoc
- switch.adoc
- tar.adoc
- to_the_end.adoc
- gcp_cloudtrace.adoc
- jaeger.adoc
- none.adoc
- open_telemetry_collector.adoc
- redpanda.adoc
- templating.adoc
- unit_testing.adoc
- about.adoc
- functions.adoc
- methods.adoc
- antora.yml
- benchmarking.md
- once.go
- once_test.go
- agent.pb.go
- agent_grpc.pb.go
- weather.py
- check_weather_tool.yaml
- .gitignore
- .python-version
- pyproject.toml
- README.md
- redpanda_agents.yaml
- uv.lock
- agent.go
- agent_plugin.go
- agent_processor.go
- template.go
- batcher.go
- batcher_test.go
- doc.go
- periodic.go
- periodic_test.go
- agent.go
- chroot_linux.go
- chroot_others.go
- connectors_list.go
- connectors_list_test.go
- custom_lint.go
- dry_run.go
- enterprise.go
- flags_common.go
- flags_redpanda.go
- flags_redpanda_test.go
- generate_plugin.go
- mcp_server.go
- mcp_server_init.go
- regexp.go
- regexp_test.go
- detect.go
- detect_test.go
- mockoidc.go
- allow_all.yaml
- deny_all.yaml
- selective.yaml
- authz.go
- authz_endpoint_test.go
- authz_grpc_test.go
- authz_test.go
- cors.go
- jwt_validator.go
- jwt_validator_test.go
- client.go
- config.go
- config_test.go
- transport.go
- transport_observability.go
- transport_observability_test.go
- transport_retry.go
- transport_retry_test.go
- transport_test.go
- interceptor.go
- processor_message.go
- processor_message_test.go
- README.md
- transport_http.go
- config.go
- input.go
- integration_test.go
- output.go
- config.go
- input.go
- input_description.adoc
- integration_service_bus_test.go
- integration_test.go
- output.go
- output_test.go
- integration_test.go
- output.go
- output_test.go
- ocf.avro
- processor.go
- processor_test.go
- scanner.go
- scanner_test.go
- processor.go
- processor_test.go
- awstest.go
- processor_chat.go
- processor_embeddings.go
- processor_embeddings_test.go
- input_logs.go
- input_logs_integration_test.go
- input_logs_test.go
- metrics.go
- metrics_test.go
- config.go
- benchmark_config.yaml
- main.go
- README.md
- Taskfile.yaml
- batcher.go
- batcher_test.go
- cache.go
- cache_integration_test.go
- cache_test.go
- checkpoint.go
- checkpoint_test.go
- input_cdc.go
- input_cdc_bench_test.go
- input_cdc_expired_iterator_test.go
- input_cdc_integration_test.go
- input_cdc_pagination_test.go
- input_cdc_test.go
- input_dynamodb_cdc_snapshot_test.go
- output.go
- output_test.go
- processor_partiql.go
- processor_partiql_test.go
- snapshot.go
- snapshot_ack.go
- snapshot_ack_test.go
- input.go
- input_checkpointer.go
- input_record_batcher.go
- input_test.go
- integration_test.go
- output.go
- output_firehose.go
- output_firehose_test.go
- output_integration_test.go
- output_test.go
- processor.go
- processor_test.go
- aws_mk_test_bucket
- aws_mk_test_queue
- aws_mk_test_stream
- docker-compose.yaml
- docker-compose.yaml
- Dockerfile
- producer.yaml
- Taskfile.yaml
- benchmark_config.yaml
- main.go
- README.md
- Taskfile.yaml
- connector.json
- docker-compose.yaml
- Dockerfile
- producer.yaml
- README.md
- Taskfile.yaml
- docker-compose.yaml
- pipeline.yaml
- producer.yaml
- README.md
- Taskfile.yaml
- cache.go
- input.go
- input_test.go
- integration_test.go
- output.go
- output_test.go
- output.go
- output_test.go
- input.go
- input_test.go
- integration_test.go
- output.go
- output_test.go
- lambda.go
- session.go
- session_test.go
- docs.go
- executor.go
- partition_key.go
- auth.go
- input_blob_storage.go
- input_cosmosdb.go
- input_queue_storage.go
- input_table_storage.go
- integration_test.go
- output_blob_storage.go
- output_cosmosdb.go
- output_data_lake.go
- output_queue_storage.go
- output_table_storage.go
- package.go
- processor_cosmosdb.go
- input.go
- integration_test.go
- output.go
- input.go
- integration_test.go
- output.go
- shared.go
- shared_test.go
- bloblang.go
- bloblang_test.go
- config_test.go
- exploration_test.go
- input_changefeed.go
- integration_test.go
- base_processor.go
- chat_processor.go
- chat_processor_test.go
- embeddings_processor.go
- json_schema_provider.go
- rerank_processor.go
- rerank_processor_test.go
- client.go
- client_test.go
- serde.go
- serde_test.go
- avro_walker.go
- avro_walker_test.go
- bloblang.go
- bloblang_test.go
- client_test.go
- common_to_avro.go
- common_to_avro_test.go
- common_to_json_schema.go
- common_to_json_schema_test.go
- ecs_avro.go
- ecs_avro_field_level_logical_type_test.go
- ecs_avro_test.go
- json_schema_coerce.go
- json_schema_coerce_bench_test.go
- json_schema_coerce_test.go
- processor_schema_registry_decode.go
- processor_schema_registry_decode_integration_test.go
- processor_schema_registry_decode_test.go
- processor_schema_registry_encode.go
- processor_schema_registry_encode_integration_test.go
- processor_schema_registry_encode_redpanda_test.go
- processor_schema_registry_encode_test.go
- serde_avro.go
- serde_avro_test.go
- serde_json.go
- serde_json_test.go
- serde_protobuf.go
- serde_protobuf_test.go
- config.go
- docs.go
- configure-server.sh
- cache.go
- cache_test.go
- client.go
- couchbase.go
- integration_test.go
- output.go
- output_test.go
- processor.go
- processor_test.go
- argon2.go
- argon2_test.go
- bcrypt.go
- bcrypt_test.go
- jwt_parse.go
- jwt_parse_test.go
- jwt_sign.go
- jwt_sign_test.go
- client.go
- integration_test.go
- output.go
- output_test.go
- logger.go
- output.go
- output_test.go
- cache_ristretto.go
- cache_ristretto_test.go
- input.go
- output.go
- session.go
- integration_test.go
- output_stream_load.go
- output_stream_load_test.go
- integration_test.go
- output.go
- integration_test.go
- output.go
- impl.go
- shlib_others.go
- shlib_unix.go
- shlib_windows.go
- .gitignore
- plugin.cc
- processor.go
- processor_test.go
- input.go
- input_test.go
- cdc.go
- cdc_test.go
- integration_test.go
- output.go
- output_test.go
- sanitize.go
- sanitize_test.go
- schema_evolution.go
- schema_evolution_test.go
- schema_resolver.go
- schema_resolver_test.go
- table_creator.go
- table_creator_test.go
- writer.go
- writer_test.go
- emulator.go
- real.go
- metadata.go
- metadata_integration_test.go
- name.go
- name_test.go
- callback.go
- dialect.go
- dialect_test.go
- filter.go
- handler.go
- metrics.go
- model.go
- model_pg.go
- model_pg_test.go
- querier.go
- querier_mock_test.go
- subscriber.go
- subscriber_integration_test.go
- subscriber_test.go
- time.go
- time_test.go
- input_spanner_cdc.go
- input_spanner_partition_batcher.go
- input_spanner_partition_batcher_test.go
- integration_spanner_cdc_test.go
- bigquery.go
- bigquery_test.go
- cache_cloud_storage.go
- input_bigquery_select.go
- input_bigquery_select_test.go
- input_cloud_storage.go
- input_pubsub.go
- input_pubsub_test.go
- integration_pubsub_test.go
- integration_test.go
- output_bigquery.go
- output_bigquery_test.go
- output_cloud_storage.go
- output_pubsub.go
- output_pubsub_test.go
- processor_bigquery_select.go
- processor_bigquery_select_test.go
- processor_vertex_ai_chat.go
- processor_vertex_ai_embeddings.go
- pubsub.go
- pubsub_mock_test.go
- tracer_cloudtrace.go
- input.go
- input_config.go
- input_test.go
- mime_type.go
- base.go
- drive_download.go
- drive_file_labels.go
- drive_search.go
- mimes.go
- input.go
- integration_test.go
- output.go
- bloblang.go
- bloblang_test.go
- connector.json
- docker-compose.yaml
- Dockerfile
- producer.yaml
- README.md
- Taskfile.yaml
- benchmark_config.yaml
- docker-compose.yaml
- kafka_benchmark_config.yaml
- README.md
- Taskfile.yaml
- catalog.go
- catalog_test.go
- .gitignore
- databricks-unity-config.yaml
- docker-compose.yaml
- example-config.yaml
- .terraform.lock.hcl
- main.tf
- outputs.tf
- storage.tf
- terraform.yml
- variables.tf
- e2e_test.go
- README.md
- Taskfile.yml
- example-config.yaml.tftpl
- main.tf
- outputs.tf
- terraform.yml
- variables.tf
- e2e_test.go
- Taskfile.yml
- .terraform.lock.hcl
- main.tf
- outputs.tf
- terraform.yml
- variables.tf
- e2e_test.go
- Taskfile.yml
- example-config.yaml.tftpl
- main.tf
- outputs.tf
- terraform.yml
- variables.tf
- e2e_test.go
- Taskfile.yml
- .gitignore
- compare.go
- parquet.go
- parquet_test.go
- partition_key.go
- partition_key_test.go
- path.go
- stats.go
- stats_test.go
- timestamp_encoding.go
- catalogx_integration_test.go
- connector_integration_test.go
- cow_delete_and_move_integration_test.go
- cow_format_version_integration_test.go
- cow_multifile_composite_integration_test.go
- cow_nested_schema_integration_test.go
- cow_partitioned_integration_test.go
- cow_row_operation_integration_test.go
- cow_row_operation_types_integration_test.go
- cow_schema_evolution_integration_test.go
- cow_temporal_data_column_integration_test.go
- cow_transform_partition_integration_test.go
- integration_test.go
- numeric_precision_test.go
- row_operation_integration_test.go
- row_operation_types_integration_test.go
- schema_evolution_test.go
- schema_metadata_timestamp_test.go
- test_helpers.go
- timestamp_encoding_integration_test.go
- shredder.go
- shredder_bench_test.go
- shredder_test.go
- temporal.go
- temporal_test.go
- committer.go
- committer_test.go
- con459_repro_test.go
- config.go
- cow.go
- cow_amplification_bench_test.go
- cow_concurrency_test.go
- cow_merge_key_roundtrip_test.go
- cow_null_key_test.go
- cow_polish_test.go
- cow_schema_evolution_disabled_test.go
- cow_temporal_data_roundtrip_test.go
- cow_test.go
- cow_type_roundtrip_test.go
- json_leaf.go
- output_iceberg.go
- output_iceberg_test.go
- prohibited_properties.go
- prohibited_properties_test.go
- recording_fs.go
- review_recommendations_test.go
- review_regressions_test.go
- router.go
- router_test.go
- row_operation_commit_test.go
- row_operation_test.go
- schema_errors.go
- timestamp_encoding.go
- timestamp_encoding_test.go
- type_inference.go
- type_inference_test.go
- type_resolver.go
- type_resolver_test.go
- value_encoding_parity_test.go
- writer.go
- writer_test.go
- metrics_influxdb.go
- metrics_influxdb_integration_test.go
- metrics_influxdb_test.go
- metrics_influxdb_types.go
- metrics_influxdb_types_test.go
- output_file.go
- output_file_test.go
- tracer_jaeger.go
- tracer_jaeger_test.go
- benchmark_test.go
- casts.go
- functions.go
- logger.go
- processor.go
- processor_test.go
- vm.go
- client.go
- client_test.go
- client.go
- filter.go
- filter_test.go
- jira_helper.go
- query.go
- query_test.go
- resources_issues.go
- resources_issues_test.go
- resources_projects.go
- resources_projects_test.go
- resources_roles.go
- resources_roles_test.go
- resources_users.go
- resources_users_test.go
- transform.go
- transform_test.go
- types.go
- types_test.go
- input_jira.go
- input_jira_integration_test.go
- input_jira_test.go
- integration_test.go
- processor_jira.go
- processor_jira_test.go
- resources.go
- bloblang_jsonpath.go
- aws.go
- global_redpanda_logger.go
- global_redpanda_status_updates.go
- global_redpanda_status_updates_test.go
- global_redpanda_writer.go
- integration_test.go
- redpanda_common_input.go
- redpanda_common_output.go
- cache_redpanda.go
- franz_client.go
- franz_headers.go
- franz_headers_test.go
- franz_reader.go
- franz_reader_ordered.go
- franz_reader_ordered_test.go
- franz_reader_test.go
- franz_reader_toggled.go
- franz_reader_toggled_test.go
- franz_reader_unordered.go
- franz_reader_unordered_test.go
- franz_shared_client.go
- franz_writer.go
- hooks.go
- hooks_test.go
- input_kafka_franz.go
- input_redpanda.go
- input_redpanda_test.go
- input_sarama_kafka.go
- input_sarama_kafka_cg.go
- input_sarama_kafka_parts.go
- input_sarama_kafka_test.go
- input_schema_registry.go
- integration_cache_test.go
- integration_connectivity_test.go
- integration_ordered_test.go
- integration_sarama_test.go
- integration_schema_registry_test.go
- integration_test.go
- integration_unordered_test.go
- lag.go
- logger.go
- output_kafka_franz.go
- output_kafka_franz_test.go
- output_redpanda.go
- output_sarama_kafka.go
- output_schema_registry.go
- redpanda_common.go
- sasl.go
- sasl_test.go
- schema_registry.go
- schema_registry_test.go
- scram.go
- testcontainers_test.go
- topic_parser.go
- topic_parser_test.go
- bloblang.go
- bloblang_test.go
- GeoIP2-Anonymous-IP-Test.mmdb
- GeoIP2-City-Test.mmdb
- GeoIP2-Connection-Type-Test.mmdb
- GeoIP2-Country-Test.mmdb
- GeoIP2-Domain-Test.mmdb
- GeoIP2-Enterprise-Test.mmdb
- GeoIP2-ISP-Test.mmdb
- GeoLite2-ASN-Test.mmdb
- bloblang_geoip.go
- bloblang_geoip_test.go
- cache.go
- cache_integration_test.go
- aws.go
- aws_test.go
- bson_util.go
- checkpoint_cache.go
- credential_refresh_integration_test.go
- input.go
- input_test.go
- integration_test.go
- schema.go
- schema_test.go
- cache.go
- common.go
- common_test.go
- conn_pool_integration_test.go
- credential_refresh_integration_test.go
- cursor_failure_integration_test.go
- input.go
- input_test.go
- integration_test.go
- output.go
- processor.go
- processor_test.go
- client.go
- input.go
- integration_test.go
- output.go
- package.go
- bloblang.go
- package.go
- processor.go
- processor_test.go
- benchmark_config.yaml
- cart.sql
- create.sql
- products.sql
- README.md
- Taskfile.yaml
- users.sql
- mssqlservertest.go
- snapshot.go
- snapshot_test.go
- stream.go
- stream_message.go
- stream_message_test.go
- batcher.go
- checkpoint_cache.go
- checkpoint_cache_test.go
- input_mssqlserver_cdc.go
- integration_test.go
- schema.go
- schema_test.go
- aws.go
- connector.json
- docker-compose.yaml
- Dockerfile
- README.md
- rpcn_benchmark_config.yaml
- setup.sql
- Taskfile.yaml
- benchmark_config.yaml
- docker-compose.yaml
- README.md
- setup.sql
- Taskfile.yaml
- connector.json
- docker-compose.yaml
- Dockerfile
- producer.yaml
- README.md
- Taskfile.yaml
- benchmark_config.yaml
- docker-compose.yaml
- producer.yaml
- README.md
- Taskfile.yaml
- benchmark_config.yaml
- cart.sql
- create.sql
- README.md
- Taskfile.yaml
- event.go
- event_test.go
- input_mysql_stream.go
- integration_test.go
- schema.go
- schema_test.go
- snapshot.go
- TYPES.md
- validate.go
- validate_test.go
- input.go
- integration_test.go
- output.go
- auth.go
- auth_test.go
- cache_kv.go
- connection.go
- docs.go
- errors.go
- input.go
- input_jetstream.go
- input_jetstream_test.go
- input_kv.go
- input_kv_test.go
- input_stream.go
- integration_jetstream_test.go
- integration_kv_test.go
- integration_nats_test.go
- integration_req_test.go
- integration_stream_test.go
- metadata.go
- output.go
- output_jetstream.go
- output_jetstream_test.go
- output_kv.go
- output_stream.go
- processor_kv.go
- processor_request_reply.go
- docker-compose.yaml
- input.go
- integration_test.go
- output.go
- command.go
- input_kafka.go
- node.go
- output_kafka.go
- .gitignore
- api.go
- base_processor.go
- chat_processor.go
- chat_processor_test.go
- embeddings_processor.go
- embeddings_processor_test.go
- moderation_processor.go
- moderation_processor_test.go
- subprocess.go
- subprocess_unix.go
- base_processor.go
- chat_processor.go
- chat_processor_test.go
- client.go
- client_test.go
- embeddings_processor.go
- embeddings_processor_test.go
- image_processor.go
- json_schema_provider.go
- speech_processor.go
- transcription_processor.go
- translation_processor.go
- aws.go
- integration_test.go
- output.go
- application.properties
- archivelog_enable.sql
- benchmark_config.yaml
- benchmark_config_debezium.yaml
- cart.sql
- cdb_setup.sql
- create.sql
- delete_users.sql
- docker-compose.debezium.yaml
- kafka-offsets.sh
- pdb_create.sql
- pluggable.sql
- products.sql
- README.md
- retention_setup.sql
- rman_setup.rman
- Taskfile.yaml
- users.sql
- events.go
- fuzz_test.go
- lob.go
- lob_parser.go
- lob_parser_test.go
- lob_test.go
- parser.go
- parser_bench_test.go
- parser_test.go
- scanner.go
- valueconverter.go
- valueconverter_test.go
- cache.go
- cache_resource.go
- config.go
- logminer.go
- logminer_test.go
- session.go
- session_test.go
- oracledbtest.go
- oracletypes.go
- snapshot.go
- snapshot_filter.go
- snapshot_filter_test.go
- snapshot_test.go
- stream.go
- stream_message.go
- batcher.go
- batcher_test.go
- checkpoint_cache.go
- checkpoint_cache_integration_test.go
- config.go
- config_test.go
- input_oracledb_cdc.go
- integration_datatypes_test.go
- integration_test.go
- multitenancy.go
- schema.go
- schema_bench_test.go
- schema_test.go
- TYPES.md
- benchmark_test.go
- conv.go
- conv_test.go
- doc.go
- export_test.go
- log.go
- log_test.go
- metric.go
- metric_test.go
- trace.go
- trace_test.go
- allow_all_grpc.yaml
- allow_all_http.yaml
- attr_test.go
- export_test.go
- input.go
- input_grpc.go
- input_grpc_test.go
- input_http.go
- input_http_test.go
- input_test.go
- integration_test.go
- metrics_otlp.go
- metrics_otlp_test.go
- mock_policy_server_test.go
- otlp.go
- output.go
- output_grpc.go
- output_http.go
- output_test.go
- schema_registry.go
- signal.go
- tls.go
- tracer_otlp.go
- tracer_otlp_test.go
- decimal.go
- decimal_test.go
- bloblang.go
- bloblang_test.go
- input_parquet.go
- input_parquet_test.go
- processor.go
- processor_decode.go
- processor_decode_test.go
- processor_encode.go
- processor_encode_test.go
- processor_test.go
- schema_coercion.go
- schema_coercion_coverage_test.go
- util.go
- client.go
- output.go
- output_test.go
- aws.go
- connector.json
- docker-compose.yaml
- Dockerfile
- producer.yaml
- README.md
- Taskfile.yaml
- benchmark_config.yaml
- cart.sql
- create.sql
- kafka_benchmark_config.yaml
- products.sql
- README.md
- Taskfile.yaml
- users.sql
- sanitize.go
- sanitize_test.go
- config.go
- connection.go
- heartbeat.go
- logical_stream.go
- monitor.go
- pglogrepl.go
- pglogrepl_test.go
- pgtype_compat.go
- pgtype_compat_test.go
- replication_message.go
- replication_message_decoders.go
- replication_message_test.go
- schema.go
- schema_test.go
- snapshotter.go
- stream_message.go
- types.go
- pgtest.go
- input_pg_stream.go
- input_pg_stream_test.go
- integration_test.go
- signaller.go
- signaller_integration_test.go
- signaller_test.go
- ssl_integration_test.go
- TYPES.md
- metrics_prometheus.go
- metrics_prometheus_test.go
- bench_test.go
- decode_common.go
- decode_dynamicpb.go
- decode_hyperpb.go
- decode_hyperpb_fallback.go
- parse.go
- structured.go
- structured_test.go
- multimodule_watcher.go
- processor_protobuf.go
- processor_protobuf_test.go
- auth_field.go
- input.go
- input_test.go
- integration_test.go
- logger.go
- output.go
- output_pusher.go
- client.go
- integration_test.go
- output.go
- point_id.go
- processor.go
- vectors.go
- integration_test.go
- output.go
- output_test.go
- timestamp.go
- cache.go
- cache_integration_test.go
- client.go
- input_list.go
- input_pubsub.go
- input_scan.go
- input_streams.go
- integration_test.go
- output_hash.go
- output_list.go
- output_pubsub.go
- output_streams.go
- processor.go
- processor_integration_test.go
- rate_limit.go
- rate_limit_integration_test.go
- rate_limit_test.go
- script_processor.go
- docker-compose.yml
- loader-streaming.yaml
- loader.yaml
- migrator.yaml
- README.md
- Taskfile.yml
- conv.go
- conv_test.go
- export_test.go
- franz.go
- integration_helpers_test.go
- integration_soak_test.go
- integration_test.go
- migrator.go
- migrator_groups.go
- migrator_groups_integration_test.go
- migrator_groups_test.go
- migrator_schema_registry.go
- migrator_schema_registry_integration_test.go
- migrator_schema_registry_test.go
- migrator_test.go
- migrator_topic.go
- migrator_topic_integration_test.go
- plumbing.go
- README.md
- TESTING.md
- redpandatest.go
- .gitignore
- go.mod
- go.sum
- README.md
- transform.go
- .gitignore
- functions.go
- integration_chaos_test.go
- processor_data_transform.go
- processor_data_transform_test.go
- serde.go
- serde_test.go
- tracer_redpanda.go
- RedpandaConnect.connectedApp
- RPCN_Test__e.object
- ChangeEvents_AccountChangeEvent.platformEventChannelMember
- ChangeEvents_ContactChangeEvent.platformEventChannelMember
- package.xml
- setup.sh
- benchmark_cdc.yaml
- benchmark_read.yaml
- benchmark_read_single.yaml
- benchmark_write.yaml
- README.md
- Taskfile.yaml
- pubsub_api.proto
- avro.go
- client.go
- pubsub_api.pb.go
- pubsub_api_grpc.pb.go
- subscription.go
- subscription_test.go
- types.go
- client.go
- client_test.go
- graphql_test.go
- salesforce_helper.go
- types.go
- .gitignore
- config.go
- export_test.go
- input_salesforce.go
- input_salesforce_cdc.go
- input_salesforce_cdc_integration_test.go
- input_salesforce_cdc_test.go
- input_salesforce_graphql.go
- input_salesforce_graphql_integration_test.go
- input_salesforce_integration_test.go
- integration_helpers_test.go
- output_salesforce.go
- output_salesforce_test.go
- README.md
- soql.go
- soql_test.go
- client.go
- processor_capture.go
- processor_capture_test.go
- transport_mock_test.go
- config.go
- config_test.go
- input.go
- integration_test.go
- output.go
- package.go
- README.md
- writer.go
- docs.go
- input.go
- input_users.go
- output_post.go
- output_reaction.go
- processor_thread.go
- README.md
- snowflake_rsa_key.p8
- snowflake_rsa_key.pem
- decimal.go
- decimal_test.go
- division.go
- int128.go
- int128_test.go
- .gitignore
- benchmark_test.go
- gcs.go
- helper.go
- server.go
- state.go
- .gitignore
- api_errors.go
- compat.go
- compat_test.go
- integration_test.go
- parquet.go
- parquet_test.go
- README.md
- rest.go
- schema.go
- schema_errors.go
- stats.go
- stats_test.go
- streaming.go
- streaming_test.go
- uploader.go
- uploader_test.go
- userdata_converter.go
- userdata_converter_test.go
- auth.go
- auth_test.go
- integration_test.go
- metrics.go
- output_snowflake_put.go
- output_snowflake_put_test.go
- output_snowflake_streaming.go
- output_streaming_test.go
- schema_evolution.go
- client.go
- watch_input.go
- watch_input_test.go
- input.go
- integration_test.go
- output.go
- clickhouse.xml
- clickhouse_init.sql
- docker-compose.yaml
- bloblang.go
- buffer_sqlite.go
- buffer_sqlite_test.go
- cache_integration_test.go
- cache_sql.go
- conn_fields.go
- conn_fields_test.go
- input_sql_raw.go
- input_sql_raw_test.go
- input_sql_select.go
- input_sql_select_test.go
- integration_test.go
- norace_test.go
- output_sql_deprecated.go
- output_sql_insert.go
- output_sql_insert_test.go
- output_sql_raw.go
- output_sql_raw_test.go
- processor_sql_deprecated.go
- processor_sql_insert.go
- processor_sql_raw.go
- processor_sql_select.go
- race_test.go
- util.go
- metrics_statsd.go
- metrics_statsd_test.go
- processor_string_split.go
- processor_string_split_test.go
- text_chunker_processor.go
- text_chunker_processor_test.go
- config_test.go
- input_tigerbeetle.go
- integration_test.go
- driver.go
- client.go
- header.go
- sse.go
- sse_lib.go
- input.go
- interface.go
- output.go
- timeplus_output_test.go
- init.go
- search_input.tmpl.yaml
- .gitignore
- build.sh
- functions.go
- processor_wazero.go
- processor_wazero_test.go
- bloblang.go
- bloblang_test.go
- package.go
- processor.go
- processor_test.go
- input_zmq4.go
- integration_test.go
- output_zmq4.go
- README.md
- service.go
- service_test.go
- shared_service.go
- metrics.go
- scanner.go
- scanner_test.go
- component_config.go
- interpreter.go
- tracer.yaml
- allow_all.yaml
- deny_all.yaml
- selective.yaml
- test_cache.yaml
- test_input.yaml
- test_output.yaml
- test_processor.yaml
- wrapper.go
- wrapper_test.go
- authz.go
- integration_test.go
- mcp.go
- run.go
- oauth2.go
- plugins_test.go
- cdc_conformance_test.go
- plugins_test.go
- plugins_test.go
- info.csv
- info.go
- info_test.go
- indexed.go
- indexed_test.go
- pool.go
- pool_test.go
- package.go
- status.pb.go
- endpoint.go
- signalling.go
- retries.go
- go.mod.tmpl
- main.go
- plugin.yaml
- go.mod.tmpl
- main.go
- plugin.yaml
- go.mod.tmpl
- main.go
- plugin.yaml
- main.py
- plugin.yaml
- pyproject.toml
- main.py
- plugin.yaml
- pyproject.toml
- main.py
- plugin.yaml
- pyproject.toml
- convert.go
- error.go
- input.pb.go
- input_grpc.pb.go
- message.pb.go
- output.pb.go
- output_grpc.pb.go
- processor.pb.go
- processor_grpc.pb.go
- signal.go
- signal_unix.go
- subprocess.go
- subprocess_test.go
- keep
- go.mod
- go.sum
- main.go
- plugin.custom_dir.yaml
- plugin.yaml
- config.go
- init.go
- input.go
- output.go
- processor.go
- processor_test.go
- protogen.go
- util.go
- schema_registry.go
- redis.go
- redis_test.go
- secrets.go
- handler.go
- handler_test.go
- oauth2.go
- oauth2_test.go
- singleton.go
- singleton_test.go
- coerce.go
- coerce_test.go
- decimal.go
- decimal_test.go
- mutex.go
- mutex_test.go
- key.pem
- logger.go
- payload.go
- README.md
- telemetry.go
- template.go
- custom_ids.go
- atomic_value.go
- Apache-2.0.txt
- Apache-2.0_header.go.txt
- cla.md
- rcl.md
- rcl_header.go.txt
- README.md
- third_party.md
- status.proto
- agent.proto
- input.proto
- message.proto
- output.proto
- processor.proto
- go.mod
- LICENSE
- package.go
- go.mod
- LICENSE
- package.go
- .gitignore
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package_32bit.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- x_benthos_extra.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- windows.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- arm_32.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- package.go
- snowflake.go
- sqlite.go
- package.go
- package.go
- cgo.go
- package.go
- package.go
- package.go
- package.go
- package.go
- x_benthos_extra.go
- license.go
- rpcn.go
- rpcnloader.go
- batch_json_input.py
- fizzbuzz_processor.py
- fizzbuzz_processor.yaml
- json_input.py
- json_input.yaml
- logging_output.py
- logging_output.yaml
- agent_pb2.py
- agent_pb2.pyi
- agent_pb2_grpc.py
- agent_pb2_grpc.pyi
- input_pb2.py
- input_pb2.pyi
- input_pb2_grpc.py
- input_pb2_grpc.pyi
- message_pb2.py
- message_pb2.pyi
- message_pb2_grpc.py
- message_pb2_grpc.pyi
- output_pb2.py
- output_pb2.pyi
- output_pb2_grpc.py
- output_pb2_grpc.pyi
- processor_pb2.py
- processor_pb2.pyi
- processor_pb2_grpc.py
- processor_pb2_grpc.pyi
- __init__.py
- _convert.py
- _grpc.py
- core.py
- errors.py
- py.typed
- .python-version
- connect.yaml
- LICENSE
- pyproject.toml
- README.md
- Taskfile.yaml
- uv.lock
- component_config_linter.go
- component_config_linter_test.go
- schema.go
- cdc.yaml
- consume.yaml
- docker-compose.yaml
- generate.yaml
- init.sql
- README.md
- dashboard.yml
- goruntime.json
- rpcn.json
- datasource.yml
- config.monitoring
- prometheus.yml
- .gitignore
- config.yaml
- docker-compose.yaml
- README.md
- Taskfile.yml
- .gitignore
- README.md
- Taskfile.yml
- benthos.json
- dashboard.yml
- datasource.yml
- config.monitoring
- prometheus.yml
- docker-compose.yaml
- generate.yaml
- out_bridge.yaml
- out_order_verify.yaml
- out_stdout.yaml
- README.md
- blob_schema.json
- docker-compose.yaml
- in.yaml
- insert_schema.sh
- out.yaml
- README.md
- ai.Dockerfile
- cloud.Dockerfile
- Dockerfile
- README.md
- redpanda-cow
- redpanda-cow
- artifacts.json
- metadata_v4_34_0.json
- metadata_v4_35_0.json
- metadata_v4_36_0_rc1.json
- plugin_uploader.py
- README.md
- requirements.txt
- requirements_test.txt
- test_plugin_uploader.py
- add_license_headers.sh
- fips_patchelf.sh
- fips_wrapper.sh
- install
- push_pkg_to_cloudsmith.sh
- push_pkg_to_gcp_ar.sh
- release_notes.sh
- sign_for_darwin.sh
- tag_bundles.sh
- third_party.md.tpl
- third_party_licenses.sh
- update_bundles.sh
- build.yml
- docker.yml
- gh.yml
- test.yml
- tools.yml
- .gitignore
- benchmark.yml
- config.tmpl.yml
- gen_benchmark_test.go
- .gitignore
- main.tf
- outputs.tf
- terraform.yml
- variables.tf
- README.md
- Taskfile.yml
- .codebook.toml
- .dockerignore
- .gitignore
- .golangci.yml
- .versions
- .yamlfmt
- CHANGELOG.md
- CLAUDE.md
- CONTRIBUTING.md
- go.mod
- go.sum
- Makefile
- README-FIPS.md
- README.md
- SECURITY.md
- Taskfile.yml
- tools.go
# Installation Guide
git clone https://github.com/redpanda-data/connect
Downloads the entire project code from GitHub to your computer.
cd connect
Moves into the project folder you just downloaded.
2. Official Install Script
Easy Recommended- Homebrew A package manager for macOS/Linux.
brew install redpanda-data/tap/redpanda
Installs the pre-built package via Homebrew β no source build required.
Pulled directly from this repo's README.
3. Docker
Easy- Git Needed to download the project code from GitHub.
- Docker Desktop Needed to build and run containers. Install it and keep it running in the background.
docker pull docker.redpanda.com/redpandadata/connect
Type this command into your terminal and run it.
docker run --rm -v /path/to/your/config.yaml:/connect.yaml docker.redpanda.com/redpandadata/connect run
Runs the built image as an actual container.
docker run --rm -p 4195:4195 docker.redpanda.com/redpandadata/connect run \
Runs the built image as an actual container.
task docker:all
Type this command into your terminal and run it.
docker run --rm \
Runs the built image as an actual container.
Pulled directly from this repo's README.
4. Python
Easypip install -r resources/plugin_uploader/requirements.txt
Installs the Python libraries listed in requirements.txt (or similar).
python <μ€νν νμΌλͺ
>.py # READMEμμ μ νν μ€ν νμΌλͺ
μ νμΈνμΈμ
Runs the Python script (or module).
5. Go
Mediumgo install -tags "x_benthos_extra" github.com/redpanda-data/connect/v4/cmd/redpanda-connect@latest
Type this command into your terminal and run it.
Pulled directly from this repo's README.
6. Make
Medium- Git Needed to download the project code from GitHub.
- Make Usually pre-installed on Linux/macOS. On Windows, install separately (e.g. via MSYS2 or WSL).
make
Compiles the code based on the generated build configuration to produce an executable.
