MCPcopy Create free account

hub / github.com/AliwareMQ/aliware-kafka-demos / functions

Functions215 in github.com/AliwareMQ/aliware-kafka-demos

⨍ Functions 215◇ Types & classes 103
↓ 60 callersMethodlog
(String payload)
kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/KafkaDemoApplication.java:22
↓ 14 callersMethodisEmpty
(String str)
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:9
↓ 10 callersMethodsleep
()
kafka-migration/src/main/java/com/alibaba/migration/cmd/AbstractMigration.java:80
↓ 7 callersMethodrun
()
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:21
↓ 6 callersMethodbuildAcsClient
(String accessKey, String secretKey, String regionId, String endPointName)
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:42
↓ 6 callersMethodclose
()
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJOSerializer.java:50
↓ 5 callersMethodgetKafkaProperties
()
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:38
↓ 5 callersMethodgetKafkaProperties
()
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:32
↓ 4 callersMethodconfigureSaslPlain
()
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:20
↓ 4 callersMethodlogError
(ClientException e)
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:56
↓ 4 callersMethodlogInfo
(RpcAcsRequest request, AcsResponse response)
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:60
↓ 3 callersMethodcmdName
()
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:17
↓ 3 callersMethodconfigure
(Map<String, ?> props, boolean isKey)
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJODeserializer.java:20
↓ 3 callersMethodconfigure
(Map<String, ?> props, boolean isKey)
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJOSerializer.java:34
↓ 3 callersMethodconfigureSasl
()
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:20
↓ 3 callersMethodgetKafkaProperties
()
kafka-java-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:18
↓ 3 callersMethodgetKafkaProperties
()
kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:9
↓ 3 callersMethodgetPartitionNum
(ZooKeeper zooKeeper, String topic)
kafka-migration/src/main/java/com/alibaba/migration/cmd/TopicMigrationFromZk.java:72
↓ 3 callersFunctionproduceMessages
(msgs)
kafka-nodejs-demo/vpc-9094/producer-generator.js:8
↓ 3 callersFunctionproduceMessages
(msgs)
kafka-nodejs-demo/vpc-ssl/producer-generator.js:8
↓ 3 callersFunctionproduceMessages
(msgs)
kafka-nodejs-demo/vpc/producer-generator.js:8
↓ 2 callersMethodDone
()
kafka-go-demo/consumer/scram_client.go:34
↓ 2 callersMethodconfigureSasl
()
kafka-java-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:9
↓ 2 callersMethodcreateConsumerGroupInYunKafka
(IAcsClient iAcsClient, String regionId, String instanceId, List<String> consumerList)
kafka-migration/src/main/java/com/alibaba/migration/cmd/AbstractMigration.java:48
↓ 2 callersMethodcreateSerde
(Class<T> clazz, Map<String, Object> serdeProps)
kafka-streams-demo/vpc/src/main/java/streams/SerdeFactory.java:11
↓ 2 callersMethodcreateTopicInYunKafka
(IAcsClient iAcsClient, String regionId, String instanceId, String topic, int partitionNum, boolean is
kafka-migration/src/main/java/com/alibaba/migration/cmd/AbstractMigration.java:16
↓ 2 callersFunctiongetFullPath
(file string)
kafka-go-demo/producer/producer.go:29
↓ 2 callersFunctiongetFullPath
(file string)
kafka-go-demo/consumer/consumer.go:32
↓ 2 callersMethodgetKafkaProperties
(String path)
kafka-migration/src/main/java/com/alibaba/migration/cmd/JavaKafkaConfigurer.java:23
↓ 2 callersFunctionhexdump
kafka-cpp-demo/vpc-ssl/kafka_consumer.c:68
↓ 2 callersFunctionhexdump
kafka-cpp-demo/vpc/kafka_consumer.c:68
↓ 2 callersMethodisEmpty
(String str)
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:9
↓ 2 callersMethodisExpired
(List<StreamFull> streams)
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:214
↓ 2 callersMethodkafkaSaslConfig
(Map<String, Object> props, PropertiesConfig propertiesConfig)
kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaSaslConfig.java:23
↓ 2 callersMethodkafkaSaslConfig
(Map<String, Object> props, PropertiesConfig propertiesConfig)
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaSaslConfig.java:23
↓ 2 callersFunctionprint_partition_list
kafka-cpp-demo/vpc-ssl/kafka_consumer.c:177
↓ 2 callersFunctionprint_partition_list
kafka-cpp-demo/vpc/kafka_consumer.c:177
↓ 2 callersFunctionproduceSingleMessage
(singleMsg)
kafka-nodejs-demo/vpc-9094/producer-generator.js:32
↓ 2 callersFunctionproduceSingleMessage
(singleMsg)
kafka-nodejs-demo/vpc-ssl/producer-generator.js:33
↓ 2 callersFunctionproduceSingleMessage
(singleMsg)
kafka-nodejs-demo/vpc/producer-generator.js:28
↓ 1 callersMethodbuildZookeeper
(String sourceZkConnect, int sourceZkSessionTimeout)
kafka-migration/src/main/java/com/alibaba/migration/cmd/zk/ZKManager.java:8
↓ 1 callersMethodconfigureSasl
(String path)
kafka-migration/src/main/java/com/alibaba/migration/cmd/JavaKafkaConfigurer.java:11
↓ 1 callersMethodconfigureSaslScram
()
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:29
↓ 1 callersMethodconsumerConfigs
消费配置
kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaConsumerConfig.java:53
↓ 1 callersMethodconsumerConfigs
消费配置
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaConsumerConfig.java:53
↓ 1 callersMethodconsumerConfigs
消费配置
kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/KafkaConsumerConfig.java:53
↓ 1 callersMethodconsumerFactory
消费消费工厂
kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaConsumerConfig.java:45
↓ 1 callersMethodconsumerFactory
消费消费工厂
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaConsumerConfig.java:45
↓ 1 callersMethodconsumerFactory
消费消费工厂
kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/KafkaConsumerConfig.java:45
↓ 1 callersMethoddependencyCheckStream
Define the processing topology for Word Count. @param builder StreamsBuilder to use
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:236
↓ 1 callersFunctiondescribe_groups
kafka-cpp-demo/vpc-ssl/kafka_consumer.c:223
↓ 1 callersFunctiondescribe_groups
kafka-cpp-demo/vpc/kafka_consumer.c:223
↓ 1 callersFunctiondoInitConsumer
(cfg *KafkaConfig)
kafka-confluent-go-demo/consumer/consumer.go:49
↓ 1 callersFunctiondoInitProducer
(cfg *KafkaConfig)
kafka-confluent-go-demo/producer/producer.go:57
↓ 1 callersMethodfindClasses
()
kafka-migration/src/main/java/com/alibaba/migration/Migration.java:100
↓ 1 callersFunctiongenerateKafkaConf
(cfg *KafkaConfig)
kafka-go-demo/producer/producer.go:60
↓ 1 callersFunctiongenerateKafkaConf
(cfg *KafkaConfig)
kafka-go-demo/consumer/consumer.go:63
↓ 1 callersMethodgetConsumerGroupListFromAliyun
(IAcsClient iAcsClient, String regionId, String instanceId)
kafka-migration/src/main/java/com/alibaba/migration/cmd/ConsumerGroupMigrationFromAliyun.java:57
↓ 1 callersMethodgetHashsetSerde
()
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:190
↓ 1 callersMethodgetProcessedBagsSerde
()
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:163
↓ 1 callersMethodgetProcessedStreamsSerde
()
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:177
↓ 1 callersMethodgetStreamCountSerde
()
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:196
↓ 1 callersMethodgetStreamsConfiguration
Configure the Streams application. <p> Various Kafka Streams related settings are defined here such as the location of the target Kafka cluster to use
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:142
↓ 1 callersMethodgetTopicListFromAliyun
(IAcsClient iAcsClient, String regionId, String instanceId)
kafka-migration/src/main/java/com/alibaba/migration/cmd/TopicMigrationFromAliyun.java:61
↓ 1 callersMethodgetValidStreams
(List<StreamFull> streams)
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:202
↓ 1 callersMethodhelp
(JCommander jCommander)
kafka-migration/src/main/java/com/alibaba/migration/Migration.java:56
↓ 1 callersMethodinitCmd
(JCommander jCommander, String[] args)
kafka-migration/src/main/java/com/alibaba/migration/Migration.java:69
↓ 1 callersMethodinitKafkaConsumer
()
kafka-migration/src/main/java/com/alibaba/migration/cmd/ConsumerGroupMigrationFromTopic.java:89
↓ 1 callersMethodisCompactTopic
(ZooKeeper zooKeeper, String topic)
kafka-migration/src/main/java/com/alibaba/migration/cmd/TopicMigrationFromZk.java:83
↓ 1 callersMethodisFullyProcessed
()
kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:92
↓ 1 callersMethodlist
(JCommander jCommander)
kafka-migration/src/main/java/com/alibaba/migration/Migration.java:46
↓ 1 callersFunctionloadJsonConfig
config should be a pointer to structure, if not, panic
kafka-go-demo/producer/producer.go:41
↓ 1 callersFunctionloadJsonConfig
config should be a pointer to structure, if not, panic
kafka-go-demo/consumer/consumer.go:44
↓ 1 callersFunctionloadJsonConfig
config should be a pointer to structure, if not, panic
kafka-confluent-go-demo/producer/producer.go:31
↓ 1 callersFunctionloadJsonConfig
config should be a pointer to structure, if not, panic
kafka-confluent-go-demo/consumer/consumer.go:22
↓ 1 callersFunctionmsg_consume
* Handle and print a consumed message. * Internally crafted messages are also used to propagate state from * librdkafka to the application. The appl
kafka-cpp-demo/vpc-ssl/kafka_consumer.c:114
↓ 1 callersFunctionmsg_consume
* Handle and print a consumed message. * Internally crafted messages are also used to propagate state from * librdkafka to the application. The appl
kafka-cpp-demo/vpc/kafka_consumer.c:114
↓ 1 callersMethodnewCmd
()
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:19
↓ 1 callersMethodproducerConfigs
()
kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaProducerConfig.java:38
↓ 1 callersMethodproducerConfigs
()
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaProducerConfig.java:38
↓ 1 callersMethodproducerConfigs
()
kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/KafkaProducerConfig.java:33
↓ 1 callersMethodproducerFactory
()
kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaProducerConfig.java:33
↓ 1 callersMethodproducerFactory
()
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaProducerConfig.java:33
↓ 1 callersMethodproducerFactory
()
kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/KafkaProducerConfig.java:28
↓ 1 callersMethodrun0
(JCommander jCommander, String[] args)
kafka-migration/src/main/java/com/alibaba/migration/Migration.java:36
↓ 1 callersMethodsendMessage
()
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/KafkaController.java:19
MethodBegin
(userName, password, authzID string)
kafka-go-demo/producer/scram_client.go:20
MethodBegin
(userName, password, authzID string)
kafka-go-demo/consumer/scram_client.go:20
MethodCleanup
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
kafka-go-demo/consumer/consumer.go:190
MethodConsumeClaim
ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().
kafka-go-demo/consumer/consumer.go:195
MethodDone
()
kafka-go-demo/producer/scram_client.go:34
MethodJsonPOJODeserializer
Default constructor needed by Kafka
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJODeserializer.java:17
MethodJsonPOJOSerializer
Default constructor needed by Kafka
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJOSerializer.java:31
MethodKafkaConsumerRunner
(KafkaConsumer consumer)
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:78
MethodKafkaConsumerRunner
(KafkaConsumer consumer)
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:98
MethodKafkaConsumerRunner
(KafkaConsumer consumer)
kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:66
MethodKafkaSaslConfig
()
kafka-spring-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/KafkaSaslConfig.java:7
MethodKafkaSaslConfig
()
kafka-spring-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaSaslConfig.java:7
MethodKafkaSaslConfig
()
kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaSaslConfig.java:20
MethodKafkaSaslConfig
()
kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaSaslConfig.java:20
next →1–100 of 215, ranked by callers