MCPcopy Create free account

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235
↓ 229 callersMethodbuild
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:156
↓ 154 callersMethodnewBuilder
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:107
↓ 124 callersMethodget
()
streams/src/main/java/bbejeck/chapter_10/PopsHopsApplication.java:112
↓ 65 callersMethodstart
(Map<String, String> props)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:59
↓ 58 callersMethodprotobufSerde
(final Class<T> theClass, final boolean isKey)
streams/src/main/java/bbejeck/utils/SerdeUtil.java:25
↓ 43 callersMethodmaybeDeleteThenCreate
(final String... names)
streams/src/main/java/bbejeck/utils/Topics.java:88
↓ 39 callersMethodsend
(final String topicName, List<V> records)
streams/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:31
↓ 38 callersMethodcreate
(final Properties props, final String name, final
streams/src/main/java/bbejeck/utils/Topics.java:32
↓ 35 callersMethodsetId
(int id)
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:43
↓ 35 callersMethodsetName
(String name)
streams/src/main/java/bbejeck/chapter_3/model/User.java:27
↓ 31 callersMethodgetBootstrapServers
()
streams/src/test/java/bbejeck/testcontainers/BaseProxyInterceptingKafkaContainerTest.java:44
↓ 28 callersMethodequals
(Object o)
streams/src/main/java/bbejeck/chapter_3/model/User.java:47
↓ 25 callersMethodtoString
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:97
↓ 22 callersMethodconfigure
(Map<String, ?> configs, boolean isKey)
streams/src/main/java/bbejeck/serializers/JsonDeserializer.java:31
↓ 19 callersMethodpoll
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:88
↓ 19 callersMethodtopology
(final Properties streamProperties)
streams/src/main/java/bbejeck/BaseStreamsApplication.java:22
↓ 18 callersMethodconsume
(final String topic, final ConsumerRecordsHandler<K, V> recordsHandler)
streams/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:31
↓ 16 callersMethodsend
(final String topicName)
sr-full/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:36
↓ 15 callersMethodgetCustomerId
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:37
↓ 15 callersMethodproduceWithRecordSupplier
(Supplier<ProducerRecord<K, V>> producerRecordSupplier, Seria
streams/src/main/java/bbejeck/clients/MockDataProducer.java:321
↓ 14 callersMethodhighestSeen
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:27
↓ 14 callersMethodnumberReadings
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:41
↓ 12 callersMethodoverrideConfigs
(final Map<String, Object> overrideConfigs)
streams/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:27
↓ 12 callersMethodoverrideConfigs
(final Map<String, Object> overrideConfigs)
streams/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:56
↓ 12 callersMethodproducerConfigs
()
streams/src/main/java/bbejeck/clients/MockDataProducer.java:383
↓ 11 callersMethodcallback
()
streams/src/main/java/bbejeck/clients/MockDataProducer.java:391
↓ 11 callersMethodclose
()
streams/src/main/java/bbejeck/utils/TestUtils.java:80
↓ 11 callersMethodgetName
()
streams/src/main/java/bbejeck/chapter_3/model/User.java:23
↓ 11 callersMethodprintKV
(String label)
streams/src/main/java/bbejeck/BaseStreamsApplication.java:34
↓ 10 callersMethoddelete
(final Properties props, final String name)
streams/src/main/java/bbejeck/utils/Topics.java:41
↓ 9 callersMethodfmtWindowed
(Windowed<K> windowed)
streams/src/main/java/bbejeck/BaseStreamsApplication.java:42
↓ 8 callersMethodaverageReading
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:68
↓ 7 callersMethodgetAmountRequested
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:45
↓ 7 callersMethodgetId
()
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:39
↓ 7 callersMethodgetTerm
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:74
↓ 7 callersMethodproduceRecordsForWindowedExample
(final String topic, long advance, ChronoUnit unit)
streams/src/main/java/bbejeck/clients/MockDataProducer.java:173
↓ 7 callersMethodtoString
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:48
↓ 6 callersMethodbuildPurchase
(String department, String customerId, double price, int qty, String cc)
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:60
↓ 6 callersMethodpartitions
(String topic, Windowed<K> windowedKey, V value, int numPartitions)
streams/src/main/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitioner.java:30
↓ 6 callersMethodstrip
(final Object obj)
streams/src/main/java/bbejeck/chapter_8/KTableAggregationExample.java:84
↓ 6 callersMethodwithApproved
(boolean approved)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:146
↓ 5 callersMethodfetch
()
streams/src/main/java/bbejeck/data/DataSource.java:10
↓ 5 callersMethodgetCreditRating
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:41
↓ 5 callersMethodgetName
()
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:31
↓ 5 callersMethodgetReportedDebt
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:53
↓ 5 callersMethodgetReportedIncome
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:49
↓ 5 callersMethodhasNext
()
streams/src/main/java/bbejeck/utils/TestUtils.java:90
↓ 5 callersMethodnext
()
streams/src/main/java/bbejeck/utils/TestUtils.java:95
↓ 5 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_8/KTableCountExample.java:29
↓ 5 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_8/KTableFilterExample.java:27
↓ 5 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingNamedProcessorsApp.java:47
↓ 5 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingAppWithPeek.java:44
↓ 5 callersMethodtopology
(final Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/RepartitionForThroughput.java:33
↓ 4 callersMethodaccept
(ConsumerRecords<K, V> consumerRecords)
streams/src/main/java/bbejeck/clients/ConsumerRecordsHandler.java:11
↓ 4 callersMethodaggregationDeserializer
()
streams/src/test/java/bbejeck/chapter_9/IotStreamingAggregationNoWindowsTest.java:29
↓ 4 callersMethodapply
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:50
↓ 4 callersMethodapply
(final CoffeePurchase coffeePurchase, final RetailPurchase retailPur
streams/src/main/java/bbejeck/chapter_7/joiner/PurchaseJoiner.java:17
↓ 4 callersMethodgeneratePurchasedItems
(final int numberRecords)
streams/src/main/java/bbejeck/data/DataGenerator.java:215
↓ 4 callersMethodgenerateRandomText
()
streams/src/main/java/bbejeck/data/DataGenerator.java:59
↓ 4 callersMethodnewRecord
(R connectRecord, Schema updatedSchema, Object updatedValue)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:78
↓ 4 callersMethodproduceProtoJoinRecords
(final JoinData<R1, R2, K1, K2> joinData)
streams/src/main/java/bbejeck/clients/MockDataProducer.java:226
↓ 4 callersMethodproducePurchasedItemsData
()
streams/src/main/java/bbejeck/clients/MockDataProducer.java:68
↓ 4 callersMethodproduceRandomTextDataWithKeyFunction
(Function<String, String> keyFunction, final String topic)
streams/src/main/java/bbejeck/clients/MockDataProducer.java:272
↓ 4 callersMethodrun
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorMonitorThread.java:45
↓ 4 callersMethodtestProperties
()
streams/src/test/java/bbejeck/chapter_8/KTableCountExampleTest.java:23
↓ 4 callersMethodtoMap
(final JsonNode jsonNode)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:133
↓ 4 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionWindows.java:43
↓ 4 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsEmitOnClose.java:49
↓ 4 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindows.java:48
↓ 4 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationEmitOnCloseTumblingWindow.java:45
↓ 4 callersMethodversion
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:196
↓ 3 callersMethodaggregationDeserializer
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsEmitOnCloseTest.java:37
↓ 3 callersMethodaggregationDeserializer
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsTest.java:34
↓ 3 callersMethodaggregationDeserializer
()
streams/src/test/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationEmitOnCloseTumblingWindowTest.java:34
↓ 3 callersMethodconfigure
(Map<String, ?> configs)
streams/src/main/java/bbejeck/chapter_4/sales/CustomOrderPartitioner.java:43
↓ 3 callersMethoddeserialize
(String topic, byte[] data)
streams/src/main/java/bbejeck/serializers/JsonDeserializer.java:22
↓ 3 callersMethodgenerateClickEvents
(int numberUsers, int numEvents)
streams/src/main/java/bbejeck/data/DataGenerator.java:297
↓ 3 callersMethodgenerateProductTransactions
(int numberRecords)
streams/src/main/java/bbejeck/data/DataGenerator.java:117
↓ 3 callersMethodgenerateUsers
(int num)
streams/src/main/java/bbejeck/data/DataGenerator.java:284
↓ 3 callersMethodget
()
streams/src/main/java/bbejeck/chapter_10/processor/DataDrivenAggregate.java:37
↓ 3 callersMethodgetConsumerInstance
(Map<String, Object> config)
streams/src/main/java/bbejeck/chapter_6/client_supplier/CustomKafkaStreamsClientSupplier.java:53
↓ 3 callersMethodgetLordOfTheRingsCharacters
(int number)
streams/src/main/java/bbejeck/data/DataGenerator.java:351
↓ 3 callersMethodgetProperties
()
streams/src/main/java/bbejeck/utils/Topics.java:119
↓ 3 callersMethodgetRecords
()
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoProducer.java:21
↓ 3 callersMethodgetRecords
()
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaProducer.java:21
↓ 3 callersMethodgetRecords
()
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:22
↓ 3 callersMethodgetTopicNames
(Admin adminClient)
streams/src/test/java/bbejeck/chapter_4/AdminClientTest.java:85
↓ 3 callersMethodgetValueSchema
(final JsonNode node)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:144
↓ 3 callersMethodisApproved
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:57
↓ 3 callersMethodoperatingValue
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:76
↓ 3 callersMethodpageViewCountSerde
()
streams/src/test/java/bbejeck/chapter_9/session/PageViewSessionWindowsTest.java:32
↓ 3 callersMethodproduceRandomTextData
()
streams/src/main/java/bbejeck/clients/MockDataProducer.java:126
↓ 3 callersMethodproduceRecords
(final KafkaProducer<String, Integer> producer)
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:125
↓ 3 callersMethodserialize
(String topic, T data)
streams/src/main/java/bbejeck/serializers/JsonSerializer.java:18
↓ 3 callersMethodsetHttpClient
(HttpClient httpClient)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:201
↓ 3 callersMethodtempThresholdExceededCount
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:50
↓ 3 callersMethodtoStruct
(Schema schema, Map<String, Object> contents)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:138
↓ 3 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/StreamsCountingApplication.java:32
↓ 3 callersMethodwithError
(String errorMessage)
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:23
↓ 2 callersMethodbuildStream
(KStream<String, String> sourceStream)
streams/src/test/java/bbejeck/chapter_6/SubtopologyTest.java:65
next →1–100 of 814, ranked by callers