kafka-client
Here are 151 public repositories matching this topic...
-
Updated
May 19, 2021 - Go
-
Updated
May 15, 2021 - Go
-
Updated
May 18, 2021 - Python
I use Array<Uint8Array> as a value. But The uint8Array is treated as string.
function arrayString(val) {
var result = '{'
for (var i = 0; i < val.length; i++) {
if (i > 0) {
result = result + ','
}
if (val[i] === null || typeof val[i] === 'undefined') {
result = result + 'NULL'
} else if (Array.isArray(val[i])) {
result = result + arrayStr-
Updated
May 20, 2021 - C#
SQL Insert Statement
Current behavior:
All the SQL activities either don't support Insert or are specific to a usecase
Expected behavior:
to be able to insert to a sql database in an activity
What is the motivation / use case for changing the behavior?
many workflows/pipelines require logging to a database
Additional information you deem important (e.g. I need this tomorrow):
-
Updated
Apr 14, 2021 - C
-
Updated
May 17, 2021 - Scala
-
Updated
May 20, 2021 - Ruby
-
Updated
Nov 26, 2020 - Java
-
Updated
Apr 13, 2021 - Rust
-
Updated
Mar 23, 2021 - Python
Typo
The error message "Hostname could not be found in context. HostNamePartitioningStrategy will not work." and variable name "hostname" are weird.
ContextNameKeyingStrategy: <-- problem code
@Override
public void setContext(Context context) {
super.setContext(context);
final String hostname = context.getProperty(CoreConstants.CONTEXT_NAME_KEY);
if (hostnamPlease add configuration option for changing /ui UI path to custom value.
-
Updated
May 13, 2021 - Clojure
based on: https://kafka.js.org/docs/configuration and tulios/kafkajs#298
We may not have the correct settings for the JSConsumer and JSProducer. This issue is to ensure we have them up to date after nodefluent/node-sinek#154 has been merged
-
Updated
Apr 22, 2020 - Java
-
Updated
May 20, 2021 - Go
Similarly to #234, it would be useful to provide functions for creating test KafkaProducers.
A good first function would be one which yields somewhat sensible default RecordMetadata.
object KafkaProducer {
def unit[F[_], K, V](implicit F: Sync[F]): F[KafkaProducer[F, K, V]] = ???
}Likely, this would require some internal state, hence F[KafkaProducer[F, K, V]].
-
Updated
May 14, 2021 - Ruby
-
Updated
Mar 9, 2021 - Java
-
Updated
Jan 19, 2018 - Java
-
Updated
May 20, 2021 - Java
-
Updated
Apr 19, 2021 - Java
-
Updated
Jul 29, 2020 - Java
-
Updated
Mar 14, 2020 - Scala
Improve this page
Add a description, image, and links to the kafka-client topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the kafka-client topic, visit your repo's landing page and select "manage topics."
https://github.com/collectd/collectd/blob/0b2796dfa3b763ed10194ccd66b39b1e056da9b9/src/mysql.c#L772
Hi,
As I saw in the source for the mysql plugin, the collector specifically ignors the Prepared_stmt_count variable.
I would like to have that in the output for collectd as well.
Is it possible to enable this key in the collectd mysql collector?
Unfortunately my C skills are pretty near zer