confluentgist’s gists

confluentgist / 00_numeric.mapping_README.md

Last active August 30, 2022 11:44 — forked from rmoff/00_numeric.mapping_README.md

Kafka Connect JDBC Connector - numeric.mapping

This is a series of gists documenting testing done with the numeric.mapping option in Kafka Connect.

—@rmoff January 9, 2019

confluentgist / suppress.java

Last active March 19, 2019 03:49 — forked from vvcephei/suppression-blog-figure-1.java

Suppress

	events
	.groupByKey()
	.windowedBy(TimeWindows.of(Duration.ofMinutes(2)))
	.count(Materialized.as("count-metric"))

	// graph servlet queries "count-metric"

confluentgist / use-case-alerting.java

Last active March 19, 2019 03:49 — forked from vvcephei/suppression-blog-figure-2.java

Use Case: Alerting

	events
	.groupByKey()
	.windowedBy(TimeWindows.of(Duration.ofMinutes(2)))
	.count(Materialized.as("count-metric"))
	.filter( _ < 4 )
	.toStream()
	.foreach( /* Send that email! */)

	// graph servlet queries "count-metric"

confluentgist / metrics-app-with-alerts.java

Last active March 19, 2019 03:48 — forked from vvcephei/suppression-blog-figure-3.java

Metrics App with Alerts

	events
	.groupByKey()
	.windowedBy(
	TimeWindows.of(Duration.ofMinutes(2).withGrace(Duration.ofMinutes(2))
	)
	.count(Materialized.as("count-metric"))
	.suppress(Suppressed.untilWindowClose(BufferConfig.unbounded()))
	.filter( _ < 4 )
	.toStream()
	.foreach( /* Send that email! */)

confluentgist / testing-your-suppressions.java

Last active March 19, 2019 03:47 — forked from vvcephei/suppression-blog-figure-4.java

Testing Your Suppressions

	driver.pipeInput(recordFactory.create(
	/* topic */ "input",
	/* key */ "A",
	/* value */ "v1",
	/* timestamp */ 10L
	));
	// Stream time is now 10L

	driver.pipeInput(recordFactory.create("input", "A", "v2", 11L));
	// Stream time is now 11L

confluentgist / reconfiguring-buffer-size-at-runtime.java

Last active March 19, 2019 03:48 — forked from vvcephei/suppression-blog-figure-5.java

Reconfiguring Buffer Size at Runtime

	builder
	.table("users")
	.suppress(Suppressed.untilTimeLimit(
	BufferConfig.maxBytes(myConfig.getUsersBufferSize())
	))
	...

confluentgist / ProcessorAPIExample.java

Created April 26, 2019 16:32 — forked from bbejeck/ProcessorAPIExample.java

	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*

confluentgist / StreamsDSLExample.java

Created April 26, 2019 20:31 — forked from bbejeck/StreamsDSLExample.java

	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*

confluentgist / StreamsDSLAndProcessorExample.java

Created April 26, 2019 20:48 — forked from bbejeck/StreamsDSLAndProcessorExample.java

	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*

confluentgist / StreamsJoinWithRepartitioning.java

Created April 26, 2019 21:13 — forked from bbejeck/StreamsJoinWithRepartitioning.java

	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*

Confluent, Inc. confluentgist