Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bbejeck/KafkaStreamsInAction2ndEdition
/ functions
Functions
814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition
⨍
Functions
814
◇
Types & classes
235
Method
qaLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:73
Method
qaLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:67
Method
qaLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplication.java:51
Method
rejectedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:62
Method
rejectedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:69
Method
rejectedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:63
Method
rejectedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplication.java:47
Method
rollupLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:71
Method
rollupLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:78
Method
runConsumer
()
streams/src/main/java/bbejeck/chapter_4/pipelining/PipeliningConsumerClient.java:37
Method
runConsumer
()
streams/src/main/java/bbejeck/chapter_4/sales/SalesConsumerClient.java:29
Method
runExchangeApplicationTest
()
streams/src/test/java/bbejeck/chapter_14/CurrencyExchangeClientTest.java:44
Method
runProducer
()
streams/src/main/java/bbejeck/chapter_4/pipelining/PipeliningProducerClient.java:30
Method
runProducer
()
streams/src/main/java/bbejeck/chapter_4/sales/SalesProducerClient.java:37
Method
sendData
()
spring-kafka/src/main/java/bbejeck/spring/datagen/MockLoanApplicationDataGenerator.java:39
Method
sendingOutputOnWindowCloseTest
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedEagerTest.java:38
Method
sendingOutputOnWindowEagerOutputTest
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedEagerTest.java:52
Method
setEmail
(String email)
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:51
Method
setFavoriteColor
(String favoriteColor)
streams/src/main/java/bbejeck/chapter_3/model/User.java:43
Method
setFavoriteNumber
(int favoriteNumber)
streams/src/main/java/bbejeck/chapter_3/model/User.java:35
Method
setHttpClient
(HttpClient httpClient)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnector.java:108
Method
setName
(String name)
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:35
Method
setReadingThreshold
(double readingThreshold)
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:64
Method
setUp
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceTaskTest.java:33
Method
setUp
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorTest.java:31
Method
setUp
()
custom-connector/src/test/java/bbejeck/chapter_5/transformer/MultiFieldExtractTest.java:26
Method
setUp
()
streams/src/test/java/bbejeck/chapter_8/KTableAggregationExampleTest.java:30
Method
setUp
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExampleTest.java:29
Method
setUp
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamTableJoinExampleTest.java:29
Method
setUp
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:29
Method
setUp
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:36
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/IotStreamingAggregationNoWindowsTest.java:35
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/session/StreamsCountSessionWindowTest.java:29
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitionerTest.java:23
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowIntegrationTest.java:47
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowTest.java:28
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedEagerTest.java:33
Method
setUp
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedStrictTest.java:29
Method
setUp
()
streams/src/test/java/bbejeck/chapter_7/StreamsPokerGameInMemoryStoreReducerTest.java:31
Method
setUp
()
streams/src/test/java/bbejeck/chapter_7/KafkaStreamsJoinsAppTest.java:32
Method
setUp
()
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:50
Method
setUp
()
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:64
Method
setUp
()
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:65
Method
setUp
()
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:53
Method
setUp
()
streams/src/test/java/bbejeck/chapter_4/TransactionalConsumeTransformProduceTest.java:60
Method
setUp
()
streams/src/test/java/bbejeck/chapter_4/AdminClientTest.java:35
Method
setUp
()
streams/src/test/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProduceConsumeTest.java:43
Method
setUp
()
streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:70
Method
setUp
()
streams/src/test/java/bbejeck/chapter_10/SensorAlertingApplicationTest.java:35
Method
setUp
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:36
Method
setUp
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceApplicationTest.java:48
Method
setUp
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:28
Method
setUp
()
streams/src/test/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuatorTest.java:30
Method
setup
()
streams/src/test/java/bbejeck/chapter_14/CurrencyExchangeClientTest.java:37
Method
shouldAggregateTwoWindows
()
streams/src/test/java/bbejeck/chapter_10/SensorAlertingApplicationTest.java:60
Method
shouldAggregateWithPunctuation
()
streams/src/test/java/bbejeck/chapter_10/SensorAlertingApplicationTest.java:88
Method
shouldConsumeAvroGenericTypeRecords
()
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:89
Method
shouldCountStream
()
streams/src/test/java/bbejeck/chapter_7/StreamsCountingApplicationTest.java:20
Method
shouldCountStream
()
streams/src/test/java/bbejeck/chapter_7/StreamsCountingInMemoryApplicationTest.java:20
Method
shouldEmitAggregationsForEveryFiveReadings
()
streams/src/test/java/bbejeck/chapter_10/SensorAlertingApplicationTest.java:141
Method
shouldHandleNullKey
()
streams/src/test/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitionerTest.java:53
Method
shouldHandleNullWindow
()
streams/src/test/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitionerTest.java:46
Method
shouldHaveHoppingWindowsTest
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowIntegrationTest.java:71
Method
shouldNotAggregateBelowThreshold
()
streams/src/test/java/bbejeck/chapter_10/SensorAlertingApplicationTest.java:122
Method
shouldPartitionSameKeyToSamePartition
()
streams/src/test/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitionerTest.java:28
Method
shouldProduceAndConsumeAvroEvents
()
streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:85
Method
shouldProduceAndConsumeDynamicTypes
()
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:104
Method
shouldProduceAndConsumeSpecificTypes
()
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:82
Method
shouldProduceConsumeAvroAvengerObjects
()
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:66
Method
shouldProduceConsumeGenericObjects
()
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:104
Method
shouldProduceConsumeJsonSchema
()
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:81
Method
shouldPunctuateRecordsTest
()
streams/src/test/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuatorTest.java:38
Method
shouldReduceScores
()
streams/src/test/java/bbejeck/chapter_7/StreamsPokerGameInMemoryStoreReducerTest.java:36
Method
shouldReduceStreams
()
streams/src/test/java/bbejeck/chapter_7/StreamsPokerGameReducerTest.java:25
Method
shouldSerializeThenDeserialize
()
streams/src/test/java/bbejeck/serializers/ProtoSerializerDeserializerTest.java:14
Method
shouldSplitStreamsNoDefault
()
streams/src/test/java/bbejeck/chapter_6/BranchTest.java:74
Method
shouldSplitStreamsWithDefault
()
streams/src/test/java/bbejeck/chapter_6/BranchTest.java:32
Method
shouldTransformNoSchema
()
custom-connector/src/test/java/bbejeck/chapter_5/transformer/MultiFieldExtractTest.java:90
Method
shouldTransformNullValue
()
custom-connector/src/test/java/bbejeck/chapter_5/transformer/MultiFieldExtractTest.java:117
Method
shouldTransformSchema
()
custom-connector/src/test/java/bbejeck/chapter_5/transformer/MultiFieldExtractTest.java:32
Method
slidingWindowTest
()
streams/src/test/java/bbejeck/chapter_9/sliding/PageViewSlidingWindowsTest.java:31
Method
specificAvroSerde
(final Properties props)
streams/src/main/java/bbejeck/utils/SerdeUtil.java:40
Method
start
(Map<String, String> props)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnector.java:37
Method
stockPerformancePunctuationManualTimeAdvanceTest
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceApplicationTest.java:70
Method
stockPerformancePunctuationTest
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceApplicationTest.java:53
Method
stockPerformancePunctuationTestNoAdvance
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceApplicationTest.java:89
Method
stop
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnector.java:85
Method
stores
()
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessorSupplier.java:24
Method
stores
()
streams/src/main/java/bbejeck/chapter_10/processor/DataDrivenAggregate.java:103
Method
taskClass
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnector.java:59
Method
tearDown
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainer.java:56
Method
tearDown
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorTest.java:39
Method
tearDown
()
custom-connector/src/test/java/bbejeck/chapter_5/transformer/MultiFieldExtractTest.java:127
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_8/KTableAggregationExampleTest.java:44
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExampleTest.java:44
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamTableJoinExampleTest.java:44
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:45
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:55
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowIntegrationTest.java:66
Method
tearDown
()
streams/src/test/java/bbejeck/chapter_7/KafkaStreamsJoinsAppTest.java:48
← previous
next →
601–700 of 814, ranked by callers