Functions — github.com/bjpublic/apache-kafka-with-java

hub / github.com/bjpublic/apache-kafka-with-java / functions

Functions138 in github.com/bjpublic/apache-kafka-with-java

⨍ Functions 138◇ Types & classes 65

MethodonSuccess

(SendResult<String, String> result)

Chapter4/4.4 spring-kafka/spring-kafka-template-producer/src/main/java/com/example/SpringProducerApplication.java:31

Methodprocess

(String key, String value)

Chapter3/3.5 kafka-streams/simple-kafka-processor/src/main/java/com/example/FilterProcessor.java:16

MethodrecordListener

(ConsumerRecord<String,String> record)

Chapter4/4.4 spring-kafka/spring-kafka-record-listener/src/main/java/com/example/SpringConsumerApplication.java:22

Methodrun

()

Chapter3/3.5 kafka-streams/queryable-store/src/main/java/com/example/QueryableStore.java:44

Methodrun

()

Chapter3/3.4.2 kafka-consumer/kafka-consumer-sync-offset-commit-shutdown-hook/src/main/java/com/example/ConsumerWithSyncOffsetCommit.java:51

Methodrun

()

Chapter5/5.1 web-page-event-pipeline/kafka-multi-consumer-thread-hdfs-save/src/main/java/com/pipeline/HdfsSinkApplication.java:40

Methodrun

()

Chapter5/5.2 metric-log-pipeline-streams/metric-kafka-streams/src/main/java/com/pipeline/MetricStreams.java:44

Methodrun

()

Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/ConsumerWorker.java:29

Methodrun

()

Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/MultiConsumerThreadByPartition.java:90

Methodrun

()

Chapter4/4.3 kafka-consumer/kafka-consumer-with-multi-worker-thread/src/main/java/com/example/ConsumerWorker.java:15

Methodrun

()

Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread/src/main/java/com/example/ConsumerWorker.java:26

MethodselectColor

( @RequestHeader("user-agent") String userAgentName, @RequestParam(value = "color")Str

Chapter5/5.1 web-page-event-pipeline/kafka-spring-producer-with-rest-controller/src/main/java/com/pipeline/ProduceController.java:27

Methodshutdown

()

Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/ConsumerWorker.java:49

MethodsingleTopicListener

(String messageValue)

Chapter4/4.4 spring-kafka/spring-kafka-record-listener/src/main/java/com/example/SpringConsumerApplication.java:28

MethodsingleTopicWithPropertiesListener

(String messageValue)

Chapter4/4.4 spring-kafka/spring-kafka-record-listener/src/main/java/com/example/SpringConsumerApplication.java:34

Methodstart

(Map<String, String> props)

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceTask.java:40

Methodstart

(Map<String, String> props)

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java:27

Methodstart

(Map<String, String> props)

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java:23

Methodstart

(Map<String, String> props)

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java:28

Methodstop

()

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceTask.java:92

Methodstop

()

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java:58

Methodstop

()

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkTask.java:57

Methodstop

()

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java:54

Methodstop

()

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkTask.java:87

Methodstop

()

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java:59

MethodstopAndWakeup

()

Chapter5/5.1 web-page-event-pipeline/kafka-multi-consumer-thread-hdfs-save/src/main/java/com/pipeline/consumer/ConsumerWorker.java:102

MethodtaskClass

()

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java:37

MethodtaskClass

()

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java:33

MethodtaskClass

()

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java:38

MethodtaskConfigs

(int maxTasks)

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java:42

MethodtaskConfigs

(int maxTasks)

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java:38

MethodtaskConfigs

(int maxTasks)

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java:43

Methodversion

()

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceTask.java:35

Methodversion

()

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java:22

Methodversion

()

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkTask.java:20

Methodversion

()

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java:18

Methodversion

()

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkTask.java:34

Methodversion

()

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java:23

← previous101–138 of 138, ranked by callers