kafka-samples-master
kafka-avro-producer-example
src
main
resources
application.yml
469B
java
rsol
example
kafka
producer
KafkaProducerServiceApplication.java
349B
controller
KafkaProducerController.java
2KB
model
UserConfigModel.java
930B
util
CommonUtil.java
679B
service
MyProducerInterceptor.java
1KB
impl
ProducerServiceImpl.java
3KB
ProducerService.java
221B
config
AppConfig.java
2KB
constants
IConstants.java
324B
test
java
com
boeing
onepdl
service
contract
KafkaProducerServiceApplicationTests.java
371B
pom.xml
2KB
README.md
42B
.gitignore
139B
kafka-consumer-example
src
main
resources
application.yml
441B
java
rsol
example
kafka
consumer
ServiceContractConfigServiceApplication.java
365B
controller
KafkaConsumerController.java
2KB
model
UserConfigModel.java
930B
listener
KafkaConsumerListener.java
1KB
util
KafkaConsumerOffsetParser.java
3KB
ConsumerOffsetDetails.java
523B
CommonUtil.java
679B
KafkaSimpleProducerClient.java
3KB
service
KafkaConsumerService.java
222B
impl
KafkaConsumerServiceImpl.java
1KB
config
AppConfig.java
888B
constants
IConstants.java
324B
test
java
com
boeing
onepdl
service
contract
ServiceContractConfigServiceApplicationTests.java
374B
pom.xml
2KB
README.md
42B
kafka-avro-consumer-example
src
main
resources
application.yml
551B
java
rsol
example
kafka
consumer
ServiceContractConfigServiceApplication.java
365B
controller
KafkaConsumerController.java
2KB
model
UserConfigModel.java
930B
listener
KafkaConsumerListener.java
928B
util
CommonUtil.java
679B
service
KafkaConsumerService.java
222B
impl
KafkaConsumerServiceImpl.java
1KB
config
AppConfig.java
888B
constants
IConstants.java
324B
test
java
com
boeing
onepdl
service
contract
ServiceContractConfigServiceApplicationTests.java
374B
pom.xml
3KB
README.md
42B
README.md
440B
spring-cloud-streams-kafka-demo
src
main
resources
application.yaml
407B
java
rsol
example
streamkafka
model
Greetings.java
352B
stream
GreetingsStreams.java
505B
service
GreetingsListener.java
598B
GreetingsService.java
1KB
web
GreetingsController.java
1020B
config
StreamsConfig.java
237B
StreamKafkaApplication.java
338B
pom.xml
3KB
spring-cloud-streams-kafka-avro-demo
src
main
resources
employee-schema.avsc
400B
employee-key-schema.avsc
202B
application.yaml
1KB
java
rsol
example
streamkafka
controller
AvroController.java
766B
producer
.gitignore
139B
MyInterceptor.java
1KB
util
SchemaValidationTest.java
4KB
TestMessageProducer.java
2KB
AvroEmployeeProducer.java
2KB
MyProducerInterceptor.java
1KB
AvroProducer.java
1KB
config
SchemRegistryConfig.java
747B
AvroKafkaApplication.java
603B
consumer
util
TestConsumer.java
3KB
AvroEmployeeConsumer.java
3KB
AvroConsumer.java
1KB
pom.xml
4KB
README.md
232B
kafka-producer-example
src
main
resources
application.yml
395B
java
rsol
example
kafka
producer
KafkaProducerServiceApplication.java
349B
controller
KafkaProducerController.java
2KB
model
UserConfigModel.java
930B
util
CommonUtil.java
679B
service
MyProducerInterceptor.java
1KB
impl
ProducerServiceImpl.java
3KB
ProducerService.java
221B
config
AppConfig.java
2KB
constants
IConstants.java
324B
test
java
com
boeing
onepdl
service
contract
KafkaProducerServiceApplicationTests.java
371B
pom.xml
2KB
README.md
42B
暂无评论