Functions — github.com/OneCricketeer/schema-registry-transfer-smt

hub / github.com/OneCricketeer/schema-registry-transfer-smt / functions

Functions72 in github.com/OneCricketeer/schema-registry-transfer-smt

⨍ Functions 72 ◇ Types & classes 21

↓ 25 callersMethodconfigure

(boolean copyKeys)

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:104

↓ 21 callersMethodapply

(R r)

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:129

↓ 15 callersMethodcreateRecord

(Schema keySchema, Object key, Schema valueSchema, Object value)

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:88

↓ 15 callersMethodregisterSchema

(final String topic, boolean isKey, final Schema schema)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:159

↓ 13 callersMethodpassSimpleMessage

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:185

↓ 10 callersMethodencodeAvroObject

(org.apache.avro.Schema schema, int sourceId, Object datum)

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:163

↓ 10 callersMethodgetSchemaRegistryClient

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:216

↓ 8 callersMethodgetUrl

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:220

↓ 6 callersMethodisBytesSchema

(Schema connectSchema)

src/main/java/cricket/jmoore/kafka/connect/transforms/ConnectSchemaUtil.java:7

↓ 6 callersMethodtoString

()

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:284

↓ 5 callersMethodgetSubject

(Request request)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:301

↓ 4 callersMethodgetName

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:318

↓ 3 callersMethodregister

(final String subject, final Schema schema)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:167

↓ 2 callersMethodcopySchema

(ByteBuffer buffer, String topic, boolean isKey)

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:202

↓ 2 callersMethodequals

(Object o)

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:270

↓ 2 callersMethodgetSubjectVersion

(String subject, Object version)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:188

↓ 1 callersMethodgetCompatibility

(String subject)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:203

↓ 1 callersMethodgetRequiredTransformConfigs

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:97

↓ 1 callersMethodlistVersions

(String subject)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:179

MethodSchemaAndId

()

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:262

MethodSchemaRegistryMock

(Role role)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:121

MethodSchemaRegistryTransfer

()

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:72

MethodafterEach

(final ExtensionContext context)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:131

Methodalias

()

src/main/java/cricket/jmoore/security/basicauth/SrcUserInfoCredentialProvider.java:8

Methodalias

()

src/main/java/cricket/jmoore/security/basicauth/SrcSaslBasicAuthCredentialProvider.java:7

Methodalias

()

src/main/java/cricket/jmoore/security/basicauth/DestUrlBasicAuthCredentialProvider.java:7

Methodalias

()

src/main/java/cricket/jmoore/security/basicauth/SrcUrlBasicAuthCredentialProvider.java:7

Methodalias

()

src/main/java/cricket/jmoore/security/basicauth/DestUserInfoCredentialProvider.java:8

Methodalias

()

src/main/java/cricket/jmoore/security/basicauth/DestSaslBasicAuthCredentialProvider.java:7

MethodapplyGlobally

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:232

MethodapplyKeySchemaNotBytes

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:207

MethodapplySchemalessKeyBytesTooShort

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:227

MethodapplySchemalessValueBytesTooShort

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:239

MethodapplyValueSchemaNotBytes

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:217

MethodbeforeEach

(final ExtensionContext context)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:136

Methodclose

()

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:240

Methodconfig

()

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:90

Methodconfigure

(Map<String, ?> props)

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:95

MethodgetName

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:255

MethodgetName

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:271

MethodgetName

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:293

MethodgetSubject

(Request request)

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:228

MethodhashCode

()

src/main/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryTransfer.java:279

Methodsetup

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:201

MethodtestBothBasicHttpAuthUserInfo

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:273

MethodtestBytesSchema

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaTest.java:12

MethodtestDestinationBasicHttpAuthImplicitDefault

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:342

MethodtestDestinationBasicHttpAuthNull

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:326

MethodtestDestinationBasicHttpAuthOmit

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:374

MethodtestDestinationBasicHttpAuthUrl

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:310

MethodtestDestinationBasicHttpAuthUserInfo

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:294

MethodtestDestinationBasicHttpAuthWrong

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:358

MethodtestEvolvingValueSchemaTransfer

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:658

MethodtestIncompatibleEvolvingValueSchemaTransfer

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:727

MethodtestKeySchemaLookupFailure

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:251

MethodtestKeySchemaTransfer

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:382

MethodtestKeyValueSchemaTransfer

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:526

MethodtestNonByteTypeSchemas

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaTest.java:23

MethodtestNullIsNotBytes

()

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaTest.java:18

MethodtestSourceBasicHttpAuthImplicitDefault

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:334

MethodtestSourceBasicHttpAuthNull

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:318

MethodtestSourceBasicHttpAuthOmit

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:366

MethodtestSourceBasicHttpAuthUrl

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:302

MethodtestSourceBasicHttpAuthUserInfo

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:286

MethodtestSourceBasicHttpAuthWrong

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:350

MethodtestTombstoneRecord

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:645

MethodtestValueSchemaLookupFailure

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:262

MethodtestValueSchemaTransfer

()

src/test/java/cricket/jmoore/kafka/connect/transforms/TransformTest.java:445

Methodtransform

(final Request request, final ResponseDefinition responseDefinition,

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:240

Methodtransform

(final Request request, final ResponseDefinition responseDefinition,

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:263

Methodtransform

(final Request request, final ResponseDefinition responseDefinition,

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:279

Methodtransform

(final Request request, final ResponseDefinition responseDefinition,

src/test/java/cricket/jmoore/kafka/connect/transforms/SchemaRegistryMock.java:311