Daniel Shuy daniel-shuy

Kafka 0.11.0.0 (Confluent 3.3.0) added support to manipulate offsets for a consumer group via cli kafka-consumer-groups command.

List the topics to which the group is subscribed

kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --describe

Note the values under "CURRENT-OFFSET" and "LOG-END-OFFSET". "CURRENT-OFFSET" is the offset where this consumer group is currently at in each of the partitions.

Reset the consumer offset for a topic (preview)

To send a request via the sandbox, you can use pm.sendRequest.

pm.test("Status code is 200", function () {
    pm.sendRequest('https://postman-echo.com/get', function (err, res) {
        pm.expect(err).to.not.be.ok;
        pm.expect(res).to.have.property('code', 200);
        pm.expect(res).to.have.property('status', 'OK');
    });
});

The standard names for indexes in PostgreSQL are:

{tablename}_{columnname(s)}_{suffix}

where the suffix is one of the following:

pkey for a Primary Key constraint;

key for a Unique constraint;

excl for an Exclusion constraint;

idx for any other kind of index;

	import akka.actor.ActorSystem
	import akka.dispatch.MessageDispatcher
	import akka.event.LoggingAdapter
	import akka.http.scaladsl.model.headers.{Authorization, OAuth2BearerToken}
	import akka.http.scaladsl.server.Directives.{optionalCookie, optionalHeaderValueByType, provide, reject}
	import akka.http.scaladsl.server.{AuthorizationFailedRejection, Directive1, Directives}
	import org.keycloak.adapters.KeycloakDeployment
	import org.keycloak.adapters.rotation.AdapterTokenVerifier
	import org.keycloak.representations.AccessToken

	import com.google.common.collect.Iterables;
	import java.util.List;
	import java.util.Set;
	import java.util.stream.Collectors;
	import javax.validation.ConstraintViolation;
	import javax.validation.ConstraintViolationException;
	import javax.ws.rs.core.MediaType;
	import javax.ws.rs.core.Response;
	import javax.ws.rs.ext.ExceptionMapper;
	import javax.ws.rs.ext.Provider;

	import javax.enterprise.context.Dependent;
	import javax.enterprise.context.RequestScoped;
	import javax.enterprise.inject.Produces;
	import javax.persistence.EntityManager;
	import javax.persistence.PersistenceContext;

	@Dependent
	public class EntityManagerProducer {
	@PersistenceContext(name = "persistence-unit") // name is Persistence Unit Name configured in persistence.xml
	private EntityManager entityManager;

	package demo.plain;

	import org.keycloak.OAuth2Constants;
	import org.keycloak.admin.client.CreatedResponseUtil;
	import org.keycloak.admin.client.Keycloak;
	import org.keycloak.admin.client.KeycloakBuilder;
	import org.keycloak.admin.client.resource.RealmResource;
	import org.keycloak.admin.client.resource.UserResource;
	import org.keycloak.admin.client.resource.UsersResource;
	import org.keycloak.representations.idm.ClientRepresentation;

	package de.tdlabs.keycloak.client;

	import com.fasterxml.jackson.databind.ObjectMapper;
	import org.keycloak.OAuth2Constants;
	import org.keycloak.RSATokenVerifier;
	import org.keycloak.admin.client.Keycloak;
	import org.keycloak.admin.client.KeycloakBuilder;
	import org.keycloak.common.VerificationException;
	import org.keycloak.jose.jws.JWSHeader;
	import org.keycloak.representations.AccessToken;