MCPcopy Create free account

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235
↓ 1 callersMethodtopology
(final Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/OptimizingStreamsRepartition.java:36
↓ 1 callersMethodtopology
(final Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/ProactiveStreamsRepartition.java:33
↓ 1 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/StreamsCountingInMemoryApplication.java:30
↓ 1 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_10/StockPerformanceApplication.java:47
↓ 1 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_10/SensorAlertingApplication.java:42
↓ 1 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_10/PopsHopsPrintingApplication.java:41
↓ 1 callersMethodupdatedSymbols
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorMonitorThread.java:66
↓ 1 callersMethodwithAmountRequested
(double amountRequested)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:131
↓ 1 callersMethodwithCreditRating
(int creditRating)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:126
↓ 1 callersMethodwithCustomerId
(String customerId)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:121
↓ 1 callersMethodwithReportedDebt
(double reportedDebt)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:141
↓ 1 callersMethodwithReportedIncome
(double reportedIncome)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:136
↓ 1 callersMethodwithResult
(T result)
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:27
↓ 1 callersMethodwithTerm
(int term)
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:151
MethodAvroConsumer
()
sr-full/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:26
MethodAvroConsumer
()
sr-backward/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:26
MethodAvroConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:22
MethodAvroConsumer
()
sr-forward/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:26
MethodAvroProducer
()
sr-full/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:22
MethodAvroProducer
()
sr-backward/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:22
MethodAvroProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:18
MethodAvroProducer
()
sr-forward/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:24
MethodAvroReferenceCollegeConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/avro/AvroReferenceCollegeConsumer.java:20
MethodAvroReferenceCollegeProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroReferenceCollegeProducer.java:16
MethodAvroReferenceCompanyConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/avro/AvroReferenceCompanyConsumer.java:20
MethodAvroReferenceCompanyProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroReferenceCompanyProducer.java:16
MethodBaseConsumer
(Class<?> keyDeserializer, Class<?> valueDeserializer)
sr-full/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:28
MethodBaseConsumer
(Class<?> keyDeserializer, Class<?> valueDeserializer)
sr-backward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:28
MethodBaseConsumer
(Class<?> keyDeserializer, Class<?> valueDeserializer)
streams/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:25
MethodBaseConsumer
(Class<?> keyDeserializer, Class<?> valueDeserializer)
sr-forward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:28
MethodBaseKafkaContainerTest
()
streams/src/test/java/bbejeck/testcontainers/BaseKafkaContainerTest.java:13
MethodBaseProducer
(final Class<?> keySerializer, final Class<?> valueSerializer)
sr-full/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:24
MethodBaseProducer
(final Class<?> keySerializer, final Class<?> valueSerializer)
sr-backward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:24
MethodBaseProducer
(final Class<?> keySerializer, final Class<?> valueSerializer)
streams/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:21
MethodBaseProducer
(final Class<?> keySerializer, final Class<?> valueSerializer)
sr-forward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:24
MethodBeerPurchaseProcessor
(final String domesticSalesSink, final String internationalSalesSink,
streams/src/main/java/bbejeck/chapter_10/processor/BeerPurchaseProcessor.java:18
MethodBuilder
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:88
MethodConcurrentRecordProcessor
(final ConcurrentLinkedDeque<Map<TopicPartition, OffsetAndMetadata>> offsetQueue,
streams/src/main/java/bbejeck/chapter_4/pipelining/ConcurrentRecordProcessor.java:34
MethodCurrency
(double exchangeRate)
streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeTransaction.java:16
MethodCurrencyExchangeClient
(final Consumer<String, CurrencyExchangeTransaction> exchangeConsumer, final
streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeClient.java:30
MethodCustomer
()
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:22
MethodDataDrivenAggregate
(final StoreBuilder<?> storeBuilder, final Predicate<Sensor> shouldAggregate,
streams/src/main/java/bbejeck/chapter_10/processor/DataDrivenAggregate.java:29
MethodDataGenerator
()
streams/src/main/java/bbejeck/data/DataGenerator.java:57
MethodFunctions
()
streams/src/main/java/bbejeck/utils/Functions.java:13
MethodIotSensorAggregation
(final double readingThreshold)
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:21
MethodIotWindowedRecordSupplier
(final String topic, final double tempThreshold)
streams/src/main/java/bbejeck/chapter_9/data/IotWindowedRecordSupplier.java:26
MethodJsonDeserializer
()
streams/src/main/java/bbejeck/serializers/JsonDeserializer.java:19
MethodJsonSchemaConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/json/JsonSchemaConsumer.java:21
MethodJsonSchemaProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaProducer.java:17
MethodJsonSchemaReferenceCollegeConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/json/JsonSchemaReferenceCollegeConsumer.java:20
MethodJsonSchemaReferenceCollegeProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaReferenceCollegeProducer.java:21
MethodJsonSchemaReferenceCompanyConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/json/JsonSchemaReferenceCompanyConsumer.java:22
MethodJsonSchemaReferenceCompanyProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaReferenceCompanyProducer.java:16
MethodJsonSerializer
()
streams/src/main/java/bbejeck/serializers/JsonSerializer.java:15
MethodKafkaStreamsContainer
(final LoanApplicationTopology loanApplicationTopology, final KafkaStreamsCon
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainer.java:30
MethodLoanAppRollup
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:19
MethodLoanApplication
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java:18
MethodLoanApplicationController
(KafkaStreams kafkaStreams, RestTemplateBuilder restTemplateBuilder)
spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationController.java:63
MethodLoanApplicationTopology
(KafkaStreamsConfiguration streamsConfigs)
spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationTopology.java:48
MethodLoggingProcessor
(String name)
streams/src/main/java/bbejeck/chapter_10/processor/LoggingProcessor.java:14
MethodMapValueProcessor
(Function<VIn, VOut> valueMapper)
streams/src/main/java/bbejeck/chapter_10/processor/MapValueProcessor.java:15
MethodMockDataProducer
()
streams/src/main/java/bbejeck/clients/MockDataProducer.java:65
MethodMockLoanApplicationDataGenerator
(KafkaTemplate<String, LoanApplication> kafkaTemplate)
spring-kafka/src/main/java/bbejeck/spring/datagen/MockLoanApplicationDataGenerator.java:35
MethodMultiEventAvroConsumerClient
(Map<String, Object> consumerConfigs)
streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroConsumerClient.java:41
MethodMultiEventAvroProducerClient
(final Map<String, Object> producerConfigs, final DataSource<SpecificR
streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProducerClient.java:36
MethodMultiEventProtoConsumerClient
(final Map<String,Object> consumerConfigs)
streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoConsumerClient.java:44
MethodMultiEventProtoProducerClient
(final Map<String, Object> producerConfigs, final DataSource<Events>
streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProducerClient.java:36
MethodNewLoanApplicationProcessor
(KafkaTemplate<String, LoanApplication> kafkaTemplate)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessor.java:33
MethodNewLoanApplicationProcessorListenerClassLevel
(KafkaTemplate<String, LoanApplication> kafkaTemplate)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorListenerClassLevel.java:35
MethodNewLoanApplicationProcessorLogTimestampKey
(KafkaTemplate<String, LoanApplication> kafkaTemplate)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorLogTimestampKey.java:54
MethodPageViewSessionsRecordSupplier
(final String topic)
streams/src/main/java/bbejeck/chapter_9/data/PageViewSessionsRecordSupplier.java:32
MethodPageViewSlidingWindowRecordSupplier
(final String topic)
streams/src/main/java/bbejeck/chapter_9/data/PageViewSlidingWindowRecordSupplier.java:31
MethodPipeliningConsumerClient
(final Map<String, Object> consumerConfigs, final RecordProcessor<String,
streams/src/main/java/bbejeck/chapter_4/pipelining/PipeliningConsumerClient.java:31
MethodPipeliningProducerClient
(Map<String, Object> producerConfigs)
streams/src/main/java/bbejeck/chapter_4/pipelining/PipeliningProducerClient.java:26
MethodProtoConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/proto/ProtoConsumer.java:23
MethodProtoDeserializer
()
streams/src/main/java/bbejeck/serializers/ProtoDeserializer.java:21
MethodProtoProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoProducer.java:17
MethodProtoReferenceCollegeConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/proto/ProtoReferenceCollegeConsumer.java:20
MethodProtoReferenceCollegeProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoReferenceCollegeProducer.java:16
MethodProtoReferenceCompanyConsumer
()
streams/src/main/java/bbejeck/chapter_3/consumer/proto/ProtoReferenceCompanyConsumer.java:20
MethodProtoReferenceCompanyProducer
()
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoReferenceCompanyProducer.java:21
MethodProxyInterceptingKafkaContainer
(final DockerImageName dockerImageName)
streams/src/test/java/bbejeck/testcontainers/BaseProxyInterceptingKafkaContainerTest.java:40
MethodQueryResponse
()
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:15
MethodResultTuple
(int totalSent, List<String> duplicates)
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:182
MethodSalesConsumerClient
(final Map<String,Object> consumerConfigs)
streams/src/main/java/bbejeck/chapter_4/sales/SalesConsumerClient.java:25
MethodSalesDataSource
(int numberRecords)
streams/src/main/java/bbejeck/chapter_4/sales/SalesDataSource.java:15
MethodSalesProducerClient
(final Map<String, Object> producerConfigs, final DataSource<ProductTransaction
streams/src/main/java/bbejeck/chapter_4/sales/SalesProducerClient.java:31
MethodStockPerformanceCancellingProcessor
(String stateStoreName, double differentialThreshold)
streams/src/main/java/bbejeck/chapter_10/cancellation/StockPerformanceCancellingProcessor.java:37
MethodStockPerformanceProcessor
(String stateStoreName)
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessor.java:25
MethodStockPerformanceProcessorSupplier
(StoreBuilder<?> storeBuilder)
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessorSupplier.java:15
MethodStockPerformancePunctuator
(double differentialThreshold, ProcessorContext<String, StockPerformance
streams/src/main/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuator.java:18
MethodStockPerformancePunctuatorOldProcessorAPI
(double differentialThreshold, ProcessorContext context,
streams/src/main/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuatorOldProcessorAPI.java:17
MethodStockTickerSourceConnectorConfig
(final Map<String, ?> configProps)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorConfig.java:38
MethodStockTickerSourceConnectorMonitorThread
(final ConnectorContext connectorContext, final int monitor
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorMonitorThread.java:35
MethodStockTickerSourceTask
(Time sourceTime)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:51
MethodTestUtils
()
streams/src/main/java/bbejeck/utils/TestUtils.java:30
MethodTopics
()
streams/src/main/java/bbejeck/utils/Topics.java:29
MethodUser
()
streams/src/main/java/bbejeck/chapter_3/model/User.java:14
MethodWindowedStreamsPartitioner
(Serializer<K> keySerializer)
streams/src/main/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitioner.java:21
MethodacceptedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:57
← previousnext →301–400 of 814, ranked by callers