Types & classes — github.com/AliwareMQ/aliware-kafka-demos

CodeHub MCPcopy Create free account

hub / github.com/AliwareMQ/aliware-kafka-demos / types & classes

Types & classes103 in github.com/AliwareMQ/aliware-kafka-demos

⨍ Functions 215◇ Types & classes 103

↓ 2 callersStructConsumer

Consumer represents a Sarama consumer group consumer

kafka-go-demo/consumer/consumer.go:178

↓ 2 callersClassProducer

kafka-dotnet-demo/vpc/producer/Producer.cs:4

ClassAbstractMigration

kafka-migration/src/main/java/com/alibaba/migration/cmd/AbstractMigration.java:12

ClassBagChecker

kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:46

kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:15

kafka-dotnet-demo/vpc-ssl/consumer/Consumer.cs:5

kafka-dotnet-demo/vpc/consumer/Consumer.cs:5

ClassConsumerDemo

@author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/ConsumerDemo.java:14

ClassConsumerDemo

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/ConsumerDemo.java:8

ClassConsumerGroupMigrationFromAliyun

kafka-migration/src/main/java/com/alibaba/migration/cmd/ConsumerGroupMigrationFromAliyun.java:13

ClassConsumerGroupMigrationFromTopic

kafka-migration/src/main/java/com/alibaba/migration/cmd/ConsumerGroupMigrationFromTopic.java:21

ClassConsumerMessageListener

kafka-spring-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/ConsumerMessageListener.java:6

ClassConsumerMessageListener

kafka-spring-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/ConsumerMessageListener.java:6

ClassConsumerMessageListener

kafka-spring-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/ConsumerMessageListener.java:6

ClassJavaKafkaConfigurer

kafka-migration/src/main/java/com/alibaba/migration/cmd/JavaKafkaConfigurer.java:7

ClassJavaKafkaConfigurer

kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:5

ClassJavaKafkaConfigurer

kafka-java-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:5

ClassJavaKafkaConfigurer

kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:5

ClassJavaKafkaConfigurer

kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java:5

ClassJsonPOJODeserializer

kafka-streams-demo/vpc/src/main/java/streams/JsonPOJODeserializer.java:9

ClassJsonPOJOSerializer

kafka-streams-demo/vpc/src/main/java/streams/JsonPOJOSerializer.java:25

StructKafkaConfig

kafka-go-demo/producer/producer.go:17

StructKafkaConfig

kafka-go-demo/consumer/consumer.go:20

StructKafkaConfig

kafka-confluent-go-demo/producer/producer.go:18

StructKafkaConfig

kafka-confluent-go-demo/consumer/consumer.go:10

ClassKafkaConfigListener

kafka-spring-stream-demo/sasl-ssl/src/main/java/com/alibaba/cloud/KafkaConfigListener.java:8

ClassKafkaConsumerConfig

Kafka消费端配置 @author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaConsumerConfig.java:23

ClassKafkaConsumerConfig

Kafka消费端配置 @author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaConsumerConfig.java:23

ClassKafkaConsumerConfig

Kafka消费端配置

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/KafkaConsumerConfig.java:23

ClassKafkaConsumerDemo

kafka-spring-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:6

ClassKafkaConsumerDemo

kafka-spring-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:6

ClassKafkaConsumerDemo

kafka-spring-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:6

ClassKafkaConsumerDemo

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/consumer/KafkaConsumerDemo.java:11

ClassKafkaConsumerDemo

kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:15

ClassKafkaConsumerDemo

kafka-java-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:15

ClassKafkaConsumerDemo

kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:15

ClassKafkaConsumerDemo

kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaConsumerDemo.java:13

ClassKafkaConsumerRunner

kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:74

ClassKafkaConsumerRunner

kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:94

ClassKafkaConsumerRunner

kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:62

ClassKafkaController

@author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/controller/KafkaController.java:12

ClassKafkaController

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/KafkaController.java:12

ClassKafkaController

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/controller/KafkaController.java:9

ClassKafkaDemoApplication

kafka-spring-stream-demo/sasl-ssl/src/main/java/com/alibaba/cloud/KafkaDemoApplication.java:13

ClassKafkaDemoApplication

kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/KafkaDemoApplication.java:13

ClassKafkaMultiConsumerDemo

本demo演示如何在一个进程内开启多个consumer同时消费topic 注意全局consumer数量不要超过订阅的topic总分区数

kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:21

ClassKafkaMultiConsumerDemo

本demo演示如何在一个进程内开启多个consumer同时消费topic 注意全局consumer数量不要超过订阅的topic总分区数

kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:21

ClassKafkaMultiConsumerDemo

本demo演示如何在一个进程内开启多个consumer同时消费topic 注意全局consumer数量不要超过订阅的topic总分区数

kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java:18

ClassKafkaProducerConfig

@author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaProducerConfig.java:20

ClassKafkaProducerConfig

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaProducerConfig.java:20

ClassKafkaProducerConfig

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/KafkaProducerConfig.java:17

ClassKafkaProducerDemo

kafka-spring-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:9

ClassKafkaProducerDemo

kafka-spring-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:9

ClassKafkaProducerDemo

kafka-spring-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:9

ClassKafkaProducerDemo

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/producer/KafkaProducerDemo.java:19

ClassKafkaProducerDemo

kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:16

ClassKafkaProducerDemo

kafka-java-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:13

ClassKafkaProducerDemo

kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:15

ClassKafkaProducerDemo

kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaProducerDemo.java:15

ClassKafkaSaslConfig

kafka-spring-demo/beta/src/main/java/com/aliyun/openservices/kafka/ons/KafkaSaslConfig.java:4

ClassKafkaSaslConfig

kafka-spring-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaSaslConfig.java:4

ClassKafkaSaslConfig

@author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/KafkaSaslConfig.java:13

ClassKafkaSaslConfig

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/KafkaSaslConfig.java:13

kafka-migration/src/main/java/com/alibaba/migration/Main.java:3

kafka-migration/src/main/java/com/alibaba/migration/Migration.java:11

ClassMigrationCmd

kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java:23

InterfaceMyInput

kafka-spring-stream-demo/sasl-ssl/src/main/java/com/alibaba/cloud/MyInput.java:6

InterfaceMyInput

kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/MyInput.java:6

InterfaceMyOutput

kafka-spring-stream-demo/sasl-ssl/src/main/java/com/alibaba/cloud/MyOutput.java:6

InterfaceMyOutput

kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/MyOutput.java:6

ClassProcessedBag

kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:52

ClassProcessedStream

kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:58

kafka-dotnet-demo/vpc-ssl/producer/Producer.cs:4

ClassProducerDemo

@author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/ProducerDemo.java:16

ClassProducerDemo

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/ProducerDemo.java:12

ClassPropertiesConfig

@author liujiang

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/config/PropertiesConfig.java:10

ClassPropertiesConfig

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/config/PropertiesConfig.java:10

ClassPropertiesConfig

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/config/PropertiesConfig.java:7

ClassSerdeFactory

kafka-streams-demo/vpc/src/main/java/streams/SerdeFactory.java:10

ClassStreamCount

kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:81

ClassStreamFull

kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java:68

ClassTopicMigrationFromAliyun

kafka-migration/src/main/java/com/alibaba/migration/cmd/TopicMigrationFromAliyun.java:13

ClassTopicMigrationFromZk

kafka-migration/src/main/java/com/alibaba/migration/cmd/TopicMigrationFromZk.java:12

ClassVpc9094Application

kafka-springboot-demo/vpc-9094/src/main/java/com/aliyun/openservices/vpc9094/Vpc9094Application.java:6

ClassVpc9094ApplicationTests

kafka-springboot-demo/vpc-9094/src/test/java/com/aliyun/openservices/vpc9094/Vpc9094ApplicationTests.java:6

ClassVpcApplication

kafka-springboot-demo/vpc/src/main/java/com/aliyun/openservices/vpc/VpcApplication.java:6

ClassVpcApplicationTests

kafka-springboot-demo/vpc/src/test/java/com/aliyun/openservices/vpc/VpcApplicationTests.java:6

ClassVpcSslKafkaDemoApplication

@author liujiang

kafka-springboot-demo/vpc-ssl/src/main/java/com/aliyun/openservices/vpcssl/VpcSslKafkaDemoApplication.java:9

ClassVpcSslKafkaDemoApplicationTests

kafka-springboot-demo/vpc-ssl/src/test/java/com/aliyun/openservices/vpcssl/VpcSslKafkaDemoApplicationTests.java:10

ClassWordCountDemo

Demonstrates, using the high-level KStream DSL, how to implement the WordCount program that computes a simple word occurrence histogram from an input

kafka-streams-demo/vpc/src/main/java/streams/WordCountDemo.java:49

StructXDGSCRAMClient

kafka-go-demo/producer/scram_client.go:14

StructXDGSCRAMClient

kafka-go-demo/consumer/scram_client.go:14

kafka-migration/src/main/java/com/alibaba/migration/cmd/zk/ZKManager.java:6

ClassZooKeeperClientWatcher

kafka-migration/src/main/java/com/alibaba/migration/cmd/zk/ZooKeeperClientWatcher.java:8

Classrd_kafka_group_info

kafka-cpp-demo/vpc-ssl/kafka_consumer.c:237

Classrd_kafka_group_info

kafka-cpp-demo/vpc/kafka_consumer.c:237

Classrd_kafka_group_list

kafka-cpp-demo/vpc-ssl/kafka_consumer.c:225

Classrd_kafka_group_list

kafka-cpp-demo/vpc/kafka_consumer.c:225

Classrd_kafka_group_member_info

kafka-cpp-demo/vpc-ssl/kafka_consumer.c:250

Classrd_kafka_group_member_info

kafka-cpp-demo/vpc/kafka_consumer.c:250

next →1–100 of 103, ranked by callers