| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
65 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[SOLR-1758] schema definition for configuration files (validation, XSD) -
Solr - [issue]
|
| ...It is too easy to make configuration errors in Solr without getting warnings. We should explore ways of validation configurations. See mailing list discussion at http://search-lucene.com/m/h... |
|
|
|
|
|
|
|
[ZOOKEEPER-3453] missing 'SET' in zkCli on windows -
ZooKeeper - [issue]
|
| ...this is printed during startup because it's missing the set'ZOO_LOG_FILE' is not recognized as an internal or external command, operable program or batch file.... |
|
|
|
|
|
|
|
kafka-configs to update broker ssl.truststore.location -
Kafka - [mail # user]
|
| ...Hi, Using kafka-configs, i wanted to update the broker truststore location to the new truststore:C:\>kafka-configs.cmd --bootstrap-server kafka-server:9443 --entity-type brokers --entity-... |
|
|
|
|
|
|
|
[KAFKA-9202] serde in ConsoleConsumer with access to headers -
Kafka - [issue]
|
| ...ML thread here : https://lists.apache.org/thread.html/ab8c3094945cb9f9312fd3614a5b4454f24756cfa1a702ef5c739c8f@%3Cusers.kafka.apache.org%3E The Deserializer interface has two methods, one th... |
|
|
|
|
|
|
|
kafka-9202: serde in ConsoleConsumer PR available -
Kafka - [mail # dev]
|
| ...Hi,Apologies for trying to get some attention on the dev list, but I was wondering if the PR linked to above issue can be reviewed and perhaps merged ? IMO it seems rather trivial, so maybe ... |
|
|
|
|
|
|
|
[expand - 7 more]
[collapse]
-
kafka-console-consumer --value-deserializer with access to headers -
Kafka - [mail # user]
|
| ...Issue created here: https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-9202On 2019/11/15 15:54:51, Jorg Heymans wrote: > Debugging into ConsoleConsumer.scala it eventually j... |
|
|
|
|
| |
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Debugging into ConsoleConsumer.scala it eventually just calls this:val convertedBytes = deserializer.map(_.deserialize(topic, nonNullBytes).toString. getBytes(Stan... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Hi,Sorry for the late reply, here is the command:kafka-console-consumer.cmd --consumer.config my-config.properties --bootstrap-server kafka-host:9443 --topic my-topic --value-deserializer my... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Thanks for helping debugging this. You can reproduce the issue using below deserializer, and invoking kafka-console-consumer with --value-deserializer=my.BasicDeserializer . As you will see,... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Hi,The issue is not that i cannot get a custom deserializer working, it's that the custom deserializer i provide implements the default method from the Deserializer interface https://github.... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Indeed, i corrected the typo but now my deserializer class is not taken into account at all and it goes back to the default deserializer. You can verify this by putting a non-existent class ... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Don't think that option is available there, specifying 'value.deserializer' in my consumer-config.properties file gives [2019-11-11 15:16:26,589] WARN The configuration 'value.serializer' wa... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Hi,I have created a class implementing Deserializer, providing an implementation for public String deserialize(String topic, Headers headers, byte[] data) that does some conditional processi... |
|
|
|
|
|
|
|
[KAFKA-8573] kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties -
Kafka - [issue]
|
| ...When using kafka-topics.cmd to connect to an SSL secured cluster, without specifying '--command-config=my-ssl.properties' an OOM is triggered: [2019-06-20 14:25:07,998] ERROR Uncaught except... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
kafka-streams correct Supplier semantics -
Kafka - [mail # user]
|
| ...Thanks for the confirmation Matthias ! On 2019/09/05 23:23:01, "Matthias J. Sax" wrote: > I must create a new instance. Only creating a `new> WrappingValueTransformer()` won't wo... |
|
|
|
|
| |
|
kafka-streams correct Supplier semantics - Kafka - [mail # user]
|
| ...Hi,If i have a ValueTransformer that wraps another ValueTransformer like:class WrappingValueTransformer implements ValueTransformer { .... final ValueTransformer delegateTransfor... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
stream.filter() based on message header -
Kafka - [mail # user]
|
| ...On 2019/07/04 12:41:58, Bruno Cadonna wrote: > Hi Jorg,> > transform(), transformValues, and process() are not stateful if you do> not add any state store to them. You only... |
|
|
|
|
| |
|
stream.filter() based on message header - Kafka - [mail # user]
|
| ...Hi, I understand that it's currently not possible to access message headers from the filter() DSL operation, is there a semantically equivalent (stateless) operation that can achieve the sam... |
|
|
|
|
|
|
|
[VOTE] Withdraw from the Apache Incubator -
Zipkin - [mail # dev]
|
| ...+1 (non-binding)Op vr 14 jun. 2019 05:49 schreef Sheng Wu :> +1 in public vote.>> Sheng Wu> Apache Skywalking, ShardingSphere, Zipkin>>>> > 在 2019年6月14日，上午10:24，Ad... |
|
|
|
|
|
|
|
|