mihkels

Topic creation command:

kafka-topics --bootstrap-server localhost:9093 --create --replication-factor 1 --partitions 1 --topic demo_test --command-config /tmp/props/consumer-ssl.properties

Producer command:

kafka-console-producer --bootstrap-server localhost:9093 --topic demo_test --producer.config /tmp/props/consumer-ssl.properties

mihkels

name: build

on:
  push:
    branches: [ main ]
  pull_request:
    branches: [ main ]
jobs:
  gradle:
    runs-on: ubuntu-latest

mihkels

@RestController
@RequiredArgsConstructor
@FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true)
public class GreetingConsumerController {
    Mono<RSocketRequester> requester;

    @GetMapping("/greet/{name}")
    public Publisher<GreetingResponse> greet(@PathVariable String name) {
        return requester.flatMap(req -> req.route("greet")
                  .data(GreetingRequest.builder().name(name).build())

mihkels

@Controller
public class GreetingProducerController {
    @MessageMapping("greet")
    Mono<GreetingResponse> greet(GreetingRequest request) {
        return Mono.just(new GreetingResponse("Hello " + request.getName() + " @ " + Instant.now()));
    }
}

mihkels

@Configuration
@RequiredArgsConstructor
@FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true)
public class RSocketConfiguration {
    RSocketProperties properties;

    @Bean
    Mono<RSocketRequester> rSocketRequester(RSocketRequester.Builder builder) {
        return builder.connectTcp("127.0.0.1", properties.getServer().getPort());
    }

mihkels

@RestController
@RequiredArgsConstructor
@FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true)
public class GreetingConsumerController {
    Mono<RSocketRequester> requester;

    @GetMapping("/greet/{name}")
    public Publisher<GreetingResponse> greet(@PathVariable String name) {
        return requester.flatMap(req -> req.route("greet")
                  .data(GreetingRequest.builder().name(name).build())

mihkels

local function keyCode(key)
  return function() hs.eventtap.keyStroke({}, key) end
end

hs.hotkey.bind({"cmd", "alt"}, 'h', keyCode('left') ,  nil,   keyCode('left'))
hs.hotkey.bind({"cmd", "alt"}, 'j', keyCode('down') ,  nil,   keyCode('down') )
hs.hotkey.bind({"cmd", "alt"}, 'k', keyCode('up')   ,  nil,   keyCode('up') )
hs.hotkey.bind({"cmd", "alt"}, 'l', keyCode('right'),  nil,   keyCode('right') )

mihkels

version: "3"
services:
  sample_app:
    # PHP 7 with ZeroMQ installed
    build: .
    depends_on:
      - filebeat
    working_dir: /app
    command: php index.php
    volumes:

mihkels

 docker stop $(docker ps -a -q) 

mihkels

"%ConEmuDrive%\Program Files\Git\bin\sh.exe" --login -i -new_console:a