kafka-client
Here are 152 public repositories matching this topic...
-
Updated
Apr 21, 2021 - Go
-
Updated
Apr 20, 2021 - Go
-
Updated
Apr 22, 2021 - Python
-
Updated
Apr 22, 2021 - C#
Is your feature request related to a problem? Please describe.
Our search analytics show that "Typescript" is a common search query in our documentation that yields no results. Since we do support Typescript, we should make sure that at the very least there is some search result that tells you that KafkaJS works with Typescript and shows a minimal example.
**Describe the solution you'd lik
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
Apr 19, 2021 - Scala
-
Updated
Apr 22, 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 (hostnam-
Updated
Apr 19, 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
Apr 21, 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
Jan 28, 2021 - Ruby
-
Updated
Mar 9, 2021 - Java
-
Updated
Jan 19, 2018 - Java
-
Updated
Apr 16, 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