MCPcopy Create free account

hub / github.com/apache/camel-kafka-connector / functions

Functions2,829 in github.com/apache/camel-kafka-connector

⨍ Functions 2,829◇ Types & classes 918
↓ 489 callersMethodput
(Collection<SinkRecord> sinkRecords)
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java:183
↓ 264 callersMethodsetProperty
(String name, Object value)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:93
↓ 164 callersMethodget
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java:134
↓ 155 callersMethoddebug
(String msg)
core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java:187
↓ 134 callersMethodinfo
(String msg)
core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java:192
↓ 103 callersMethodconf
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java:82
↓ 99 callersMethodconf
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnectorConfig.java:123
↓ 74 callersMethodvalue
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java:63
↓ 72 callersMethodtoString
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:78
↓ 70 callersMethoderror
(String msg)
core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java:202
↓ 68 callersMethodwarn
(String msg)
core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java:197
↓ 61 callersMethodgetName
()
tests/itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/Customer.java:49
↓ 56 callersMethodbuild
()
tests/itests-common-http/src/test/java/org/apache/camel/kafkaconnector/common/services/mockweb/MockWebService.java:126
↓ 56 callersMethodequals
(Object obj)
tests/itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/Customer.java:66
↓ 56 callersMethodgetTopicForTest
(Object testObject)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/AbstractKafkaTest.java:79
↓ 52 callersMethodgetProperties
Gets the properties used to configure the connector @return a Properties object containing the set of properties for the connector
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/ConnectorPropertyFactory.java:36
↓ 50 callersMethodwithName
(String name)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:30
↓ 46 callersMethodgetBody
(ResultSet resultSet)
tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/clients/dao/TestResultSetConversionStrategy.java:34
↓ 46 callersMethodwithConnectorClass
(String connectorClass)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:42
↓ 46 callersMethodwithKeyConverterClass
(String converterClass)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:48
↓ 46 callersMethodwithTasksMax
(int tasksMax)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:36
↓ 45 callersMethodwithTopics
(String topics)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/SinkConnectorPropertyFactory.java:27
↓ 45 callersMethodwithValueConverterClass
(String converterClass)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:60
↓ 44 callersMethodstart
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java:35
↓ 41 callersMethodgetBootstrapServers
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java:82
↓ 41 callersMethodrunTest
A simple test runner that follows the steps: initialize, start consumer, produce messages, verify results @param connectorPropertyFactory A factory f
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSinkTestSupport.java:42
↓ 38 callersMethodgetKafkaService
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/AbstractKafkaTest.java:62
↓ 37 callersMethodgetCms
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java:380
↓ 32 callersMethodconfigure
(CamelContext camelContext)
tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/RouteConfigurator.java:23
↓ 32 callersMethodgetProducerTemplate
()
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java:70
↓ 32 callersMethodkey
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java:58
↓ 32 callersMethodpoll
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java:195
↓ 32 callersMethodreceive
Receives data from a JMS queue or topic @param predicate the predicate used to test each received message @throws JMSException
tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/clients/JMSClient.java:169
↓ 30 callersMethodbuilder
()
tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSServiceFactoryWithTimeout.java:30
↓ 30 callersMethodget
()
tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java:54
↓ 29 callersMethodwithKafkaTopic
(String value)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/IdempotencyConfigBuilder.java:59
↓ 28 callersMethodget
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/AbstractCamelKafkaConnectorMojo.java:200
↓ 28 callersMethodsetName
(String name)
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:42
↓ 27 callersMethodgetCms
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java:253
↓ 27 callersMethodstart
(Map<String, String> props)
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java:82
↓ 27 callersMethodstop
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java:283
↓ 26 callersMethodconsumedMessages
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/TestMessageConsumer.java:26
↓ 24 callersMethodapply
(R r)
core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java:57
↓ 23 callersMethodgetConsumerTemplate
()
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java:82
↓ 22 callersMethodgetCamelContext
()
core/src/main/java/org/apache/camel/kafkaconnector/transforms/CamelTransformSupport.java:28
↓ 21 callersMethodbuild
(CamelContext camelContext)
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java:223
↓ 21 callersMethodclassRef
(String className)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:99
↓ 21 callersMethodgetName
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:38
↓ 20 callersMethodappend
(String name, String value)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/EndpointUrlBuilder.java:43
↓ 20 callersMethodbuildSchemaBuilderForType
Try to build a {@link SchemaBuilder} for a value of type {@link Object} However, this will only build the schema only for known types, in case it can
core/src/main/java/org/apache/camel/kafkaconnector/utils/SchemaHelper.java:44
↓ 20 callersMethodcreate
()
core/src/test/java/org/apache/camel/kafkaconnector/test/TestBlockingQueueFactory.java:37
↓ 20 callersMethodwithArgument
(String argument)
tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SfdxCommand.java:30
↓ 19 callersMethodstop
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java:34
↓ 14 callersMethodcreateService
(Supplier<AWSInfraService> supplier)
tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSServiceFactoryWithTimeout.java:34
↓ 14 callersMethodgetMainDepArtifactId
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java:161
↓ 13 callersMethodgetHostname
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/utils/NetworkUtils.java:120
↓ 13 callersMethodtoPath
(String resource)
tests/itests-https/src/test/java/org/apache/camel/kafkaconnector/https/sink/CamelSinkHTTPSITCase.java:162
↓ 12 callersMethodgetCamelSinkConnectorConfig
(Map<String, String> props)
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java:167
↓ 12 callersMethodgetFreePort
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/utils/NetworkUtils.java:41
↓ 12 callersMethodgetKafkaConnectService
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/AbstractKafkaTest.java:66
↓ 12 callersMethodgetMainDepArtifactId
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java:164
↓ 12 callersMethodlog
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/ConnectorPropertyFactory.java:38
↓ 12 callersMethodproduce
Sends data to a topic @param topic the topic to send data to @param message the message to send @throws ExecutionException @throws InterruptedExcep
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java:139
↓ 11 callersMethodbuildUrl
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/EndpointUrlBuilder.java:75
↓ 11 callersMethodbuilder
()
tests/itests-common-http/src/test/java/org/apache/camel/kafkaconnector/common/services/mockweb/MockWebService.java:98
↓ 11 callersMethodgetEvents
()
core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java:174
↓ 11 callersMethodsetCommonProperties
(Properties amazonConfigs, Map<String, String> style, BasicConnecto
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/AWSPropertiesUtils.java:33
↓ 10 callersMethodapply
(R r)
core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java:52
↓ 10 callersMethodexecute
Execute goal. @throws MojoExecutionException execution of the main class or one of the threads it generated failed. @throws MojoFailureEx
tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java:106
↓ 10 callersMethodgetInstance
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/PluginPathHelper.java:151
↓ 10 callersMethodgetType
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:30
↓ 9 callersMethodconfigure
(Map<String, ?> configs)
core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java:109
↓ 9 callersMethodgetDescription
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:70
↓ 9 callersMethodload
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/utils/PropertyUtils.java:43
↓ 9 callersMethodrunTestBlocking
A simple blocking test runner that follows the steps: initialize, start producer, consume messages, verify results @param connectorPropertyFactory A
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java:97
↓ 9 callersMethodsetTitle
(String title)
tooling/camel-kafka-connector-model/src/main/java/org/apache/camel/kafkaconnector/model/CamelKafkaConnectorModel.java:46
↓ 9 callersMethodwithBeans
(String name, String value)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/BasicConnectorPropertyFactory.java:54
↓ 9 callersMethodwithEntry
(String key, Object value)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/IdempotencyConfigBuilder.java:33
↓ 8 callersMethodclose
()
core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java:81
↓ 8 callersMethodgetArtifactId
()
tooling/camel-kafka-connector-model/src/main/java/org/apache/camel/kafkaconnector/model/CamelKafkaConnectorModel.java:58
↓ 8 callersMethodgetCamelSinkEndpointConfigPrefix
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java:175
↓ 8 callersMethodlogRecordContent
(Logger logger, LoggingLevel level, ConnectRecord<?> record)
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java:131
↓ 8 callersMethodnewRecord
(R record, Schema updatedSchema, Object updatedValue)
core/src/main/java/org/apache/camel/kafkaconnector/transforms/CamelTypeConverterTransform.java:102
↓ 8 callersMethodrunTest
(ConnectorPropertyFactory connectorPropertyFactory)
tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSStartupITCase.java:85
↓ 8 callersMethodtrace
(String msg)
core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java:182
↓ 7 callersMethodbuilder
(String from, String to)
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java:94
↓ 7 callersMethodcombineDefaultAndLoadedProperties
Combines default properties with loaded properties with the following logic: 1) loaded properties overwrite default properties. 2) default properties
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java:102
↓ 7 callersMethodgetCamelSourcePathConfigPrefix
()
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java:325
↓ 7 callersMethodgetName
()
tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/dto/CamelKafkaConnectorTableOptionModel.java:28
↓ 7 callersMethodgetRequiredProperties
()
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:62
↓ 7 callersMethodinitializeConnector
(ConnectorPropertyFactory propertyFactory)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java:31
↓ 7 callersMethodinitializeConnectorBlocking
(ConnectorPropertyFactory propertyFactory, Integer expectedTasksnumber)
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectService.java:32
↓ 7 callersMethodsetType
(String type)
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/model/KameletModel.java:34
↓ 7 callersMethodwaitForData
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSinkTestSupport.java:126
↓ 7 callersMethodwriteFileIfChanged
(String newContent, File file, Log log)
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/MavenUtils.java:121
↓ 6 callersMethodbasic
()
tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelJMSPropertyFactory.java:48
↓ 6 callersMethodcapturingClose
(MessageProducer closeable)
tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/clients/JMSClient.java:66
↓ 6 callersMethodcreateQueue
(String queue)
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/clients/AWSSQSClient.java:62
↓ 6 callersMethodcsvToSet
(String csv)
tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/MavenUtils.java:258
↓ 6 callersMethodend
()
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/ComponentConfigBuilder.java:41
next →1–100 of 2,829, ranked by callers