Jendrik Poloczek jpzk

I hereby claim:

To claim this, I am signing this object:

I hereby claim:

To claim this, I am signing this object:


	import React from 'react';
	import { render, Box, Text } from 'ink';

	import { useInput, useApp } from 'ink';
	import { Tabs, Tab, TabProps } from 'ink-tab';
	import { useState, useEffect } from 'react';
	import Table from 'ink-table'
	import TextInput from 'ink-text-input';

	import sys
	watermark = 0
	with open('blocknumbers') as f:
	current = int(f.readline())
	if(current % 1000 == 0):
	print(current)
	if not (watermark + 1 == int(current)):
	print("inconsistency at " + str(watermark) + ", " + str(current));
	sys.exit(-1)
	watermark = current

	package com.github.simplesteph.udemy.kafka.streams

	import java.lang
	import java.util.Properties

	import org.apache.kafka.clients.consumer.ConsumerConfig
	import org.apache.kafka.common.serialization.Serdes
	import org.apache.kafka.streams.kstream.{KStream, KStreamBuilder, KTable}
	import org.apache.kafka.streams.{KafkaStreams, KeyValue, StreamsConfig}


	package au.com.simplesteph.kafka.kafka0_11.demo

	import java.util.Properties

	import org.apache.kafka.clients.producer.{KafkaProducer, Producer, ProducerConfig, ProducerRecord}
	import org.apache.kafka.common.KafkaException
	import org.apache.kafka.common.errors.AuthorizationException
	import org.apache.kafka.common.errors.OutOfOrderSequenceException
	import org.apache.kafka.common.errors.ProducerFencedException

	import slick.jdbc.PostgresProfile
	import slick.jdbc.PostgresProfile.api._

	import scala.concurrent.Await
	import scala.concurrent.ExecutionContext.Implicits.global
	import scala.concurrent.duration.Duration

	class ExtractorConfig(tag: Tag) extends Table[(String, Long, String)](tag, "configs") {
	def name = column[String]("name", O.PrimaryKey)

	apt install peco
	apt install curl

	curl http://localhost:8081/subjects \| jq .[] \| tr -d "\"" \| peco \| xargs -I '{}' curl -v -X DELETE http://localhost:8081/subjects/'{}'

	import com.twitter.util._
	import com.twitter.conversions.time._

	val timer = new MockTimer()

	def schedule(timer: Timer) = {
	timer.schedule(1.second) {
	println("statement")
	}
	}