How to get client id from Kafka Consumer
If you want to read clientid from Kafka Consumer, you may use this method:
READ MOREsimply about difficult
If you want to read clientid from Kafka Consumer, you may use this method:
READ MORESuppose that you need to create Kafka Java consumer with Kerberos. The code will be: You don’t need to specify java.security.auth.login.config Java property, because we set SaslConfigs.SASL_JAAS_CONFIG property directly to the consumer. You just need to made changes in kafkaJaasConfiguration() method that necessary for your Kerberos configuration.
READ MOREThe problem can be appears in Hadoop’s NodeManager logs. Usually it means that NodeManager is trying to use an expired / not renewed HDFS delegation token. For example, you can face this error while app log aggregation process. The timeline is: Your application pass HDFS delegation token to the NodeManager through the ContainerLaunchContext class, because […]
READ MOREWhen you try to compile Groovy with Java and use gmavenplus plugin for that purpose, you may face with this errors: To solve this problem, you need replace the ‘8’ to ‘1.8’ in your maven-compiler-plugin: If you don’t have maven-compiler-plugin – add it to your project’s pom.xml, as above.
READ MORESometimes you need to set java.security.auth.login.config property programmatically. Here is how you can do it. Just modify LoginConfig class to satisfy your needs:
READ MOREFull exception text: This can happen when some process overwrites application files in HDFS application directory while app is running. An example of the situation: You start app instance_1, which stores the distribution files in the hdfs://tmp/app folder. After a while you start the second instance_2 which stores the distribution files in the same HDFS […]
READ MOREIf you need to view lifetime of your Kerberos ticket in Hadoop’s UserGroupInformation or see Kerberos ticket expiration date in UserGroupInformation (and do other things), you need extract Kerberos TGT from UserGroupInformation. This piece of code will be very useful for you:
READ MORESometimes you need to generate heavy CPU load in your app for testing purposes. if you are using Spring, it will be very convenient to run multi-threaded password hashing: That code is non-blocking, so your program are not going to pause. If you want to pause, you may add the line to the end of […]
READ MOREThere is a lot of pre-configured metrics in Ignite that disabled for default. If you want to see them, you may pass instance of LogExporterSpi to IgniteConfiguration like that: You can work with Ignite metrics by some number of ways, not only through the logging system. For example: JMX SQL Views OpenCensus Please, refer to […]
READ MORELet’s assume, that you already have configured SLF4J in your project. It remains to do two things. Add dependency: Configure Ignite:
READ MORE