User Tools

Site Tools


kafkamain

This is an old revision of the document!


Infrastructure (Understanding)
Connector list
Debugging
Configuration Summaries
connect schema registry auth
SQL Server cdc
create role kafkacdc AUTHORIZATION db_datareader
GO
create login kafkaconnect with password=***
GO
create user kafkaconnect for login kafkaconnect
GO
alter role kafkacdc add member kafkaconnect
GO
EXEC sys.sp_cdc_enable_db
GO
EXEC sys.sp_cdc_enable_table
@source_schema = N'dbo',
@source_name   = N'Products', 
@role_name     = N'kafkacdc',  
@filegroup_name = N'PRIMARY',
@supports_net_changes = 0
GO

KSQLDB
single message transform
All configurations
Julie Ops sh

#!/usr/bin/env bash

JULIE_OPS_HOME=/usr/local/julie-ops JULIE_OPS_JAR=$JULIE_OPS_HOME/bin/julie-ops.jar JAVA_PATH=java

if [ -z “$JULIE_OPS_OPTIONS” ]; then

JULIE_OPS_OPTIONS=""

fi

$JAVA_PATH $JULIE_OPS_OPTIONS -jar $JULIE_OPS_JAR “$@”

kafkamain.1665515400.txt.gz · Last modified: 2022/10/11 21:10 by rklein