| import static org.junit.Assert.assertThat; | |
| import static org.springframework.kafka.test.hamcrest.KafkaMatchers.hasKey; | |
| import static org.springframework.kafka.test.hamcrest.KafkaMatchers.hasValue; | |
| import static org.springframework.kafka.test.utils.KafkaTestUtils.getSingleRecord; | |
| import java.util.Map; | |
| import org.apache.kafka.clients.consumer.Consumer; | |
| import org.apache.kafka.clients.consumer.ConsumerConfig; | |
| import org.apache.kafka.clients.consumer.ConsumerRecord; | |
| import org.apache.kafka.common.serialization.Deserializer; |
| @Bean | |
| public ConcurrentKafkaListenerContainerFactory<String, GenericRecord> | |
| kafkaListenerContainerFactory() { | |
| ConcurrentKafkaListenerContainerFactory<String, GenericRecord> factory | |
| = new ConcurrentKafkaListenerContainerFactory<>(); | |
| factory.setConsumerFactory(consumerFactory()); | |
| factory.getContainerProperties().setErrorHandler(new ErrorHandler() { |
| /* | |
| * Available context bindings: | |
| * COLUMNS List<DataColumn> | |
| * ROWS Iterable<DataRow> | |
| * OUT { append() } | |
| * FORMATTER { format(row, col); formatValue(Object, col) } | |
| * TRANSPOSED Boolean | |
| * plus ALL_COLUMNS, TABLE, DIALECT | |
| * | |
| * where: |
| plugins { | |
| id 'java' | |
| id 'application' | |
| } | |
| repositories { | |
| jcenter() | |
| } | |
| dependencies { |
| StreamsBuilder builder = new StreamsBuilder(); | |
| builder | |
| .stream("inJlinkTopic", Consumed.with(Serdes.String(), Serdes.String())) | |
| .peek((key, value) -> log.info("Received message: {}", value)) | |
| .filter((key, value) -> "PASS".equals(value)) | |
| .to("outJlinkTopic", Produced.with(Serdes.String(), Serdes.String())); | |
| KafkaStreams streams = new KafkaStreams(builder.build(), config); | |
| streams.start(); |
| /** | |
| * Copyright (C) 2014 Couchbase, Inc. | |
| * | |
| * Permission is hereby granted, free of charge, to any person obtaining a copy | |
| * of this software and associated documentation files (the "Software"), to deal | |
| * in the Software without restriction, including without limitation the rights | |
| * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | |
| * copies of the Software, and to permit persons to whom the Software is | |
| * furnished to do so, subject to the following conditions: | |
| * |
Here are my attempts to script an IntelliJ-based IDE.
IDE Scripting Console is backed by JSR-223 (javax.script.*) API.
Groovy, Clojure, JavaScript and other scripting languages may be used.
Open IDE Scripting Console, type a statement, hit Ctrl-Enter to execute the current line or selection.
.profile.language-extension file in the same directory will be executed along with it if present.
Here are my attempts to script an IntelliJ-based IDE.
IDE Scripting Console is backed by JSR-223 (javax.script.*) API.
Groovy, Clojure, JavaScript and other scripting languages may be used.
Open IDE Scripting Console, type a statement, hit Ctrl-Enter to execute the current line or selection.
.profile.language-extension file in the same directory will be executed along with it if present.
| <?xml version="1.0" encoding="UTF-8"?> | |
| <jmeterTestPlan version="1.2" properties="4.0" jmeter="4.0 r1823414"> | |
| <hashTree> | |
| <TestPlan guiclass="TestPlanGui" testclass="TestPlan" testname="Test Plan" enabled="true"> | |
| <stringProp name="TestPlan.comments"></stringProp> | |
| <boolProp name="TestPlan.functional_mode">false</boolProp> | |
| <boolProp name="TestPlan.tearDown_on_shutdown">true</boolProp> | |
| <boolProp name="TestPlan.serialize_threadgroups">false</boolProp> | |
| <elementProp name="TestPlan.user_defined_variables" elementType="Arguments" guiclass="ArgumentsPanel" testclass="Arguments" testname="User Defined Variables" enabled="true"> | |
| <collectionProp name="Arguments.arguments"> |
| dataByAirportStream.join(regressionsByAirPortTable, | |
| (k, v) -> k, | |
| DataRegression::new) | |
| .mapValues(Predictor::predict) |