mjuarez

1

votes
0

answer
6

views

Can IntelliJ be configured to hit a breakpoint in a Java class that is loaded at runtime through reflection?

I have a Java class that is being loaded at runtime through reflection for a Kafka Streams application, configured with passing the name of the class as a String, like this: streamsConfig.put(StreamsConfig.DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG, 'com.company.data.kstreams.Processor.MediaTimestampE...
mjuarez
1

votes
2

answer
372

views

Check for the existence of a Kafka topic programatically in Java

How can I know if a topic has been created in a Kafka cluster, programatically, without using CLI tools, and before trying to produce into the topic? I'm running into a problem where the topic doesn't exist, and our application is trying to produce to a non-existent topic, but it's only notified a...
mjuarez
1

votes
1

answer
51

views

How can I get access to the original records when joining Kafka Streams

I have a working Kafka Streams app, that is currently creating two KStreams from two different topics. That part is working just fine. Now, I want to join them, and get an 'aggregated-record' of the value in the first, and the value in the second one. The keys are simple Java strings, and the valu...
mjuarez
1

votes
1

answer
27

views

IntelliJ keymaps for teams

I vaguely remember there being an option in IntelliJ a few years ago, where you could specify a 'centralized' keymap repository, which would allow all team members using IntelliJ to use the same exact keymapping. This is perfect, for example, if you're pair-programming. However, I've recently looke...
mjuarez
4

votes
1

answer
111

views

Is this a bug in MySQL query parsing?

I was running some queries, and ran into something which I think looks like a MySQL bug. I ran the following query: select s.id, a.name as a_name, s.label, st.name as st_name, -- substr(f.name FROM 1 FOR locate('cl', f.name)-2), -- substr(f.name FROM locate('cl', f.name)-2 FOR 1), substr(f.name FRO...
mjuarez
3

votes
4

answer
1.6k

views

Scala debugging under IntelliJ is horribly slow

I'm currently tracing through a relatively small Scala program (Apache's Kafka) with IntelliJ 10.5.4, while at the same time running several other Java applications in another project. While the Java applications are doing just fine, the Scala debugging is horribly slow, a simple 'Make Project' wil...
mjuarez
2

votes
1

answer
798

views

Lucene 4.3.1 backup process

I have a working Lucene 4.3.1 cluster, and I'm adding an automatic hot-backup process, similar to what's described in the 'Lucene in Action' book from Manning, and several blog posts out there. However, the book is based on Lucene 2.3, and the API has changed slightly in 4.3.1. The book says to in...
mjuarez
4

votes
1

answer
2.5k

views

How to convert a Java Collection/List to a Scala seq?

I'm trying to instantiate a Kafka Scala case class from Java code, and it has the following signature: case class OffsetFetchRequest(groupId: String, requestInfo: Seq[TopicAndPartition], versionId: Short = OffsetFetchRequest.CurrentVersion, correlationId: Int = 0, clientId: String = OffsetFetchReque...
mjuarez
3

votes
1

answer
176

views

Setting max entries on OpenHTF ChronicleMap

I'm playing around with ChronicleSet, which is backed by ChronicleMap. I've done some initial testing, and it's pretty good for our needs. Much more efficient in RAM usage than other solutions, with access time a bit slower, but still pretty fast. However, one thing I'm testing is setting the maxim...
mjuarez
10

votes
3

answer
7.7k

views

Complete list of MessageDigest available in the JDK

I've searched high and low for this, but I can't seem to get a straight answer. In Java, the available MessageDigests are determined by which security providers you have configured/installed. But assuming just a normal JDK8 install (1.8.0_11 in my case), what's the list of hash algorithms that are...
mjuarez