How can i assign the existing topic partition to newly added node ? ... View more

@Greg Keys I am having the same issue with hdf 3.3.1. I have checked the schema file and the input file as well. I have done what was mentioned by @Sriharsha Chintalapani Schema { "namespace": "hdf.heaptrace.com", "type": "record", "name": "PatientField", "fields": [ {"name": "Patient_name","type": "string"} ] } JSON data {"Patient_name":"john"} Please help !!! I have converted data from json to avro and then back again as well using avro tools. ... View more

@Kirk DeMumbrane saw your comments. Will need to send upgrades scripts against 3.0 release. ... View more

It did the trick for me. I sure hope it helps out @Joan Viladrosa, too! Thanks, Sriharsha! ... View more

Looks like openscoring also offers jpmml under a BSD license for a fee, see below. Unfortunately, it appears there's a gray area between "we just want to use the software" and "want to redistribute proprietary software based on this code." The wording of the attached blurb from openscoring suggests they think "use" of AGPL code is fine, even though the FSF stance seems to be that GNU AGPL is only compatible w/ GPL: https://www.gnu.org/licenses/why-affero-gpl.en.html ... View more

Why would you put a Google Drive link to something protected in a blog post? 🙂 ... View more

Helped me big time! Thank you for sharing! Kafka all-the-way! ... View more

HDP kafka has a patch for old client api (consumer, producer) to work with kerberorized kafka cluster. So you need to make sure the dependencies you set are coming from the hortonworks maven repo <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.8.2.0</version> ");"><exclusions> ");"><exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> ");"><exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> The above is from Apache. You can use this http://repo.hortonworks.com/content/groups/public/org/apache/kafka/kafka_2.10/0.9.0.2.4.2.8-3/ instead of the above. Add repo.hortonworks.com as one of the maven repo and use the version 0.9.0.2.4.2.8-3 instead of 0.8.2.0 like above. ... View more