Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/AnAngryMan/KafkaSimpleExample
/ functions
Functions
15 in github.com/AnAngryMan/KafkaSimpleExample
⨍
Functions
15
◇
Types & classes
10
↓ 1 callers
Method
consumerConfigs
()
src/main/java/com/imooc/kafka/config/KafkaConsumerConfig.java:58
↓ 1 callers
Method
consumerFactory
()
src/main/java/com/imooc/kafka/config/KafkaConsumerConfig.java:49
↓ 1 callers
Method
producerConfigs
()
src/main/java/com/imooc/kafka/config/KafkaProducerConfig.java:36
↓ 1 callers
Method
producerFactory
()
src/main/java/com/imooc/kafka/config/KafkaProducerConfig.java:48
↓ 1 callers
Method
send
(String topic, MessageEntity message)
src/main/java/com/imooc/kafka/producer/SimpleProducer.java:20
↓ 1 callers
Method
toString
()
src/main/java/com/imooc/kafka/common/MessageEntity.java:14
Method
ProducerCallback
(long startTime, String key, MessageEntity message)
src/main/java/com/imooc/kafka/producer/ProducerCallback.java:21
Method
Response
(int code, String message)
src/main/java/com/imooc/kafka/common/Response.java:12
Method
kafkaListenerContainerFactory
()
src/main/java/com/imooc/kafka/config/KafkaConsumerConfig.java:40
Method
kafkaTemplate
()
src/main/java/com/imooc/kafka/config/KafkaProducerConfig.java:54
Method
main
(String[] args)
src/main/java/com/imooc/kafka/ExamplesApplication.java:11
Method
onFailure
(Throwable ex)
src/main/java/com/imooc/kafka/producer/ProducerCallback.java:48
Method
onSuccess
(@Nullable SendResult<String, MessageEntity> result)
src/main/java/com/imooc/kafka/producer/ProducerCallback.java:28
Method
receive
(MessageEntity message)
src/main/java/com/imooc/kafka/consumer/SimpleConsumer.java:16
Method
sendKafka
()
src/main/java/com/imooc/kafka/controller/ProduceController.java:30